Sha256: bfc6752ecb87ebf633cb51fb91da0b1d1477e5e042dd06838f7dc09f20375b3a

Contents?: true

Size: 233 Bytes

Versions: 8

Compression:

Stored size: 233 Bytes

Contents

class WebHandler < Kafkr::Consumer::Handler
  def handle?(message)
    can_handle? message, "web"
  end

  def handle(message)
    puts message
    if message["sync"]
      reply to: message, payload: {test: "set"}
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
kafkr-0.18.0 handlers/web_handler.rb
kafkr-0.13.0 handlers/web_handler.rb
kafkr-0.11.0 handlers/web_handler.rb
kafkr-0.10.0 handlers/web_handler.rb
kafkr-0.9.1 handlers/web_handler.rb
kafkr-0.5.7 handlers/web_handler.rb
kafkr-0.5.6 handlers/web_handler.rb
kafkr-0.5.5 handlers/web_handler.rb