gistfile1.txt

require 'rubygems'
require 'mq'

EM.run do

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