round-robin-q.rb

require 'rubygems'
require 'mq'

AMQP.start do
  1000.times { |i| MQ.queue('A').publish("A #{i}") }
  1000.times { |i| MQ.queue('B').publish("B #{i}") }

  amq = MQ.new
  amq.queue('A').subscribe do |msg|
    p [ Time.now, msg ]
  end

  amq = MQ.new
  amq.queue('B').subscribe do |msg|
    p [ Time.now, msg ]
  end

end