gistfile1.txt

#!/usr/bin/env ruby
#

require 'rubygems'
require 'mq'

AMQP.start{ 
  i = 0
  10.times do
    i += 1
    puts "publishing #{i}"
    MQ.queue(ARGV[0]).publish(i)
    puts "z" * 50
    sleep 2
  end
  AMQP.stop { EM.stop }
}