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

3 entries across 3 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.1.3	features/support/sample_consumers.rb
bmabey-rosetta_queue-0.2.0	features/support/sample_consumers.rb
cwyckoff-rosetta_queue-0.3.3	features/support/sample_consumers.rb