Contents

$: << 'lib'

require 'hot_bunnies'


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

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

exchange.publish("POISON!", :routing_key => 'xyz')

subscription = queue.subscribe(:ack => true)
subscription.each(:blocking => true) do |headers, msg|
  puts msg
  headers.ack
  if msg == "POISON!"
    :cancel
  end
end

puts "ALL DONE!"

at_exit do
  channel.close
  connection.close
end

Version data entries

19 entries across 19 versions & 1 rubygems

Version	Path
hot_bunnies-1.5.0-java	examples/blocking_subscription.rb
hot_bunnies-1.4.0-java	examples/blocking_subscription.rb
hot_bunnies-1.4.0.pre4-java	examples/blocking_subscription.rb
hot_bunnies-1.4.0.pre3-java	examples/blocking_subscription.rb
hot_bunnies-1.4.0.pre2-java	examples/blocking_subscription.rb
hot_bunnies-1.4.0.pre1-java	examples/blocking_subscription.rb
hot_bunnies-1.3.8-java	examples/blocking_subscription.rb
hot_bunnies-1.3.7-java	examples/blocking_subscription.rb
hot_bunnies-1.3.6-java	examples/blocking_subscription.rb
hot_bunnies-1.3.5-java	examples/blocking_subscription.rb
hot_bunnies-1.3.4-java	examples/blocking_subscription.rb
hot_bunnies-1.3.3-java	examples/blocking_subscription.rb
hot_bunnies-1.3.2-java	examples/blocking_subscription.rb
hot_bunnies-1.3.1-java	examples/blocking_subscription.rb
hot_bunnies-1.2.2-java	examples/blocking_subscription.rb
hot_bunnies-1.2.1-java	examples/blocking_subscription.rb
hot_bunnies-1.2.0-java	examples/blocking_subscription.rb
hot_bunnies-1.1.3-java	examples/blocking_subscription.rb
hot_bunnies-1.1.2-java	examples/blocking_subscription.rb