$:.unshift File.dirname(__FILE__) + '/../lib'
require 'mq'
 
EM.run do
  
  # open a channel on the AMQP connection
  channel = MQ.new
 
  # declare a queue on the channel
  queue = MQ::Queue.new(channel, 'queue name')
 
  # use the default fanout exchange
  exchange = MQ::Exchange.new(channel, :fanout, 'all queues')
 
  # bind the queue to the exchange
  queue.bind(exchange)
 
  # publish a message to the exchange
  exchange.publish('hello world')
 
  # subscribe to messages from the queue 
  queue.subscribe do |headers, msg|
    p [:got, headers, msg]
  end
  
end