#!/usr/bin/ruby

require 'bunny'

sender, receiver = [1,2].map do
  Bunny.new('amqp://localhost').tap do |c|
    c.start
  end
end

msg = "HELLO WORLD!"

# send a message
send_channel = sender.create_channel
send_queue = send_channel.queue('ruby-bunny-autopkgtest')
send_queue.publish(msg)
puts 'I: sent message: %s' % msg

# receive message
receive_channel = receiver.create_channel
receive_queue = receive_channel.queue('ruby-bunny-autopkgtest')
info, medatata, payload = receive_queue.pop
puts 'I: received message: %s' % payload

fail("%s != %s" % [msg, payload]) if msg != payload
