simple.rb

$:.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