Contents

require 'rubygems'
require File.dirname(__FILE__) + '/../init.rb'
require File.expand_path(File.dirname(__FILE__) + '/../lib/rosetta_queue/consumer_managers/threaded')
RosettaQueue.logger = Logger.new(File.expand_path(File.dirname(__FILE__) + '/../../log/rosetta_queue.log'))

module RosettaQueue

  Adapter.define do |a|
    a.user      = "rosetta"
    a.password  = "password"
    a.host      = "localhost"
    a.type      = 'amqp_synch'
  end

  Destinations.define do |dest|
    dest.map :foo, "queue.foo"
  end  

  class MessageHandlerFoo
    include RosettaQueue::MessageHandler
    subscribes_to :foo
    options :ack => true
    attr_reader :msg

    def on_message(msg)
      puts "FOO received message: #{msg}"
    end

  end

#   consumer = RosettaQueue::Consumer.new(MessageHandlerFoo.new)
# #  Thread.new(consumer) do |cons|
#     consumer.receive
# #  end 
#   puts "sleeping for 10"
#   sleep 10
#   puts "shutting consumer down"
#  consumer.disconnect

  ThreadedManager.create do |m|
    m.add MessageHandlerFoo.new
    m.start
  end 

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
cwyckoff-rosetta_queue-0.3.3	examples/sample_amqp_consumer.rb