AMQP Example

queue_test.rb

require 'amqp'

AMQP.start 'amqp://localhost' do
  puts 'Connected.'
  AMQP::Channel.new do |channel, open_ok|
    channel.queue "schwartz.test2", :durable => false do |queue, ok|
      queue.subscribe do |headers, msg|
        puts "Got message: #{msg}"
      end
      EM.add_periodic_timer 5 do
        3.times do |i|
          AMQP.channel.default_exchange.publish(
            "A new message #{i} from #{Time.now.strftime('%H:%M:%S %m/%b/%Y')}", 
            :routing_key => queue.name )
        end
        puts "Sent messages..."
      end
      puts 'plz wait...'
    end
  end


  puts "running..."
  ['HUP','INT','TERM'].each do |sig|
    Signal.trap sig do
      puts "Terminating..."
      AMQP.connection.close { EM.stop { exit } }
    end
  end
end