Example 2 for "Messaging for Rubyists"

example2.rb

require 'bunny'

# connecting to a broker
b = Bunny.new({}, {:spec => "09"})
b.start

# setup
e = b.exchange("exchange-02", :durable => true)
q = b.queue("queue-02")
q.bind e

# producer
e.publish("Message Body", :persistent => true)

# consumer
msg = q.pop
puts "This is the message: #{msg}"
puts "This is the payload: #{msg[:payload]}"

b.stop