Contents

require File.expand_path(File.dirname(__FILE__) + '/env.rb')

class SampleConsumer
  include ::RosettaQueue::MessageHandler
  subscribes_to :foo
  options :durable => true

  attr_reader :msg

  def on_message(msg)
    @msg = msg
    puts "MESSAGE #{msg}"
  end

end


class SampleConsumerTwo
  include ::RosettaQueue::MessageHandler
  subscribes_to :foo
  options :durable => true

  attr_reader :msg

  def on_message(msg)
    @msg = msg
  end

end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.3.3	features/support/sample_consumers.rb
rosetta_queue-0.5.2	features/support/sample_consumers.rb
rosetta_queue-0.5.0	features/support/sample_consumers.rb
rosetta_queue-0.4.0	features/support/sample_consumers.rb