reader.rb

require "rubygems"
require "mq"
require "shared"

EM.run do
  @connection = AMQP.connect(:host => "localhost", :user => "carllerche", :pass => "enter", :vhost => "/testing")
  @channel = MQ.new(@connection)
  @xchange = @channel.fanout('my_exchange', :durable => true)
  
  EM.add_timer(1) do
    @xchange.publish(Marshal.dump(Awesome.new("Hello")))
    EM.add_timer(1) { EM.stop_event_loop }
  end
end

shared.rb

class Awesome
  def initialize(message)
    @message = message
  end
  attr_accessor :message
end

writer.rb

require "rubygems"
require "mq"
require "shared"

EM.run do
  trap("INT")  { EM.stop }
  trap("TERM") { EM.stop }
  
  @connection = AMQP.connect(:host => "localhost", :user => "carllerche", :pass => "enter", :vhost => "/testing")
  @channel = MQ.new(@connection)
  @xchange = @channel.fanout('my_exchange', :durable => false)
  queue = MQ::Queue.new(@channel, 'my_queue', :durable => false)
  queue.bind(@xchange)
  queue.subscribe do |header, msg|
    puts "GOT: #{Marshal.load(msg).message}"
  end
end