My message queue code

gistfile1.txt

require 'bundler/setup'
require 'bunny'

class MessageQueue
	def initialize
		@conn = Bunny.new(ENV['QUEUE'])
		@queue_name = ENV['QUEUE_NAME']
	end
	def push(service)
		puts " [x] Sending #{service} on #{@queue_name}"
		@conn.start
		ch   = @conn.create_channel
		q    = ch.queue(@queue_name)
		ch.default_exchange.publish(service.to_json, :routing_key => q.name)
		puts " [x] Sent #{service} on #{@queue_name}"
		@conn.close
	end
end

require 'bundler/setup'
require 'test/unit'
require_relative "../src/MessageQueue"

class TestEndToEnd < Test::Unit::TestCase

def test_sending_message
message = {"_id"=>"x67Aa7je", "type"=>"point-to-point"}
(0..100).each do |i|
message_queue = MessageQueue.new
message_queue.push(message)
end

end
end

[1/1] TestEndToEnd#test_sending_message [x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sending {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
[x] Sent {"_id"=>"x67Aa7je", "type"=>"point-to-point"} on test.queue
/home/developer/.rvm/rubies/ruby-2.0.0-p247/lib/ruby/2.0.0/test/unit.rb:796:in `write': execution expired (Bunny::ConnectionTimeout)