publisher.rb

require 'eventmachine'
require 'mq'

module Echo
  def initialize(mq)
    @mq = mq
  end
  def receive_data(data)
    @mq.queue('log').publish(data)
  end
end

AMQP.start(:host => 'localhost') do
  mq = MQ.new
  f = File.open(ARGV[0], "r")
  EventMachine::attach(f, Echo, mq)
end

reader.rb

require 'mq'

AMQP.start(:host => 'localhost') do
  amq = MQ.new
  amq.queue('log').subscribe{ |msg|
    print msg
  }
end