snippet.txt

require 'rubygems'
require 'eventmachine'
require 'mq'
require 'amqp'
AMQP.logging = true
AMQP.start(:user => 'nanite', :pass => 'testng', :vhost => '/nanite', :host => 'localhost', :port => ::AMQP::PORT, :insist => false, :retry => 5) {
  clock = MQ.new.fanout("clock", :durable => true)
  EM.add_periodic_timer(1) {
    puts 'tick!'
    clock.publish(Marshal.dump(Time.now))
  }
  amq = MQ.new
  amq.queue('every second').bind(amq.fanout('clock')).subscribe{ |time|
    puts 'every second', :received, Marshal.load(time)
  }
}