$: << 'lib'

require 'hot_bunnies'

import java.util.concurrent.Executors


connection = HotBunnies.connect(:host => 'localhost')
channel = connection.create_channel
channel.prefetch = 10

exchange = channel.exchange('test', :type => :direct)

queue = channel.queue('hello.world')
queue.bind(exchange, :routing_key => 'xyz')
queue.purge

thread_pool = Executors.new_fixed_thread_pool(3)

subscription = queue.subscribe(:ack => true)
subscription.each(:blocking => false, :executor => thread_pool) do |headers, msg|
  puts msg
  headers.ack
end

100.times do |i|
  exchange.publish("hello world! #{i}", :routing_key => 'xyz')
end

thread_pool.shutdown_now
subscription.cancel

puts "ALMOST ALL DONE!"

at_exit do
  channel.close
  connection.close
end