gistfile1.rbx

require 'rubygems'
require 'mq'

EM.run do

  def log(*args)
    p args
  end
    
  amq = MQ.new
  amq.queue('serv').subscribe do |msg|
    log :recv, msg
    amq.fanout('all').publish(msg)
  end
  
  amq = MQ.new
  all = amq.fanout('all')
  amq.queue('c1').bind(all)
  amq.queue('c2').bind(all)
  amq.queue('c3').bind(all)
  
end