Contents

require "messaging"

# A consume only example
class ConsumerProcessor
  include Messaging::Consumer

  subscribe("exchange", "direct", "queue", "key")

  def on_message(meta, payload)
    log.info("ConsumeProcessor channel #{meta.channel.id} received payload #{payload.inspect}")
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
amqp-subscribe-many-0.2.1	examples/consumer_processor.rb
amqp-subscribe-many-0.2.0	examples/consumer_processor.rb
amqp-subscribe-many-0.1.7	examples/consumer_processor.rb
amqp-subscribe-many-0.1.6	examples/consumer_processor.rb
amqp-subscribe-many-0.1.5	examples/consumer_processor.rb
amqp-subscribe-many-0.1.4	examples/consumer_processor.rb
amqp-subscribe-many-0.1.3	examples/consumer_processor.rb
amqp-subscribe-many-0.1.2	examples/consumer_processor.rb