Bunny Publisher and AMQP Subscriber

amqp_publisher.rb

require 'rubygems'
require 'amqp'
 
ROUTING_KEY = "test1"
AMQP.start(:host => 'localhost') do
 MQ.queue(ROUTING_KEY).publish("hello world")
 # AMQP.stop { EM.stop }
end

amqp_subscriber.rb

require 'rubygems'
require 'amqp'
 
ROUTING_KEY = "test1"
AMQP.start(:host => 'localhost' ) do |connection|
  channel = AMQP::Channel.new(connection)
  q = MQ.queue(ROUTING_KEY)
  q.subscribe do |msg|
    puts msg
  end
end

bunny_publisher.rb

require 'rubygems'
require 'bunny'
 
ROUTING_KEY = "test1"
@channel = Bunny.new(:host => 'localhost')
@channel.start
@exchange = @channel.exchange("", :auto_delete => true)
@exchange.publish "hello world", :key => ROUTING_KEY