gistfile1.rbx

#require 'rubygems'
require 'amqp/lib/mq'

EM.run do

  def log(*args)
    p args
  end
  
  # AMQP.logging = true
  
  amq = MQ.new
  world1 = amq.direct("world1")

  amq.queue("pat-serv", :auto_delete => true).bind(world1).subscribe do |msg|
    log :recv, msg
  end
end