examples/eventmachine_adapter/queue_bind.rb in amq-client-0.7.0.alpha14 vs examples/eventmachine_adapter/queue_bind.rb in amq-client-0.7.0.alpha15
- old
+ new
@@ -13,10 +13,10 @@
AMQ::Client::Queue.new(client, channel, "amqclient.queue2").declare do |queue, declare_ok|
puts queue.class.name
puts "Queue #{queue.name.inspect} is now declared!"
queue.bind("amq.fanout") do
- puts "Queue #{queue.name} is now bound to amq.fanout"
+ puts "Queue #{queue.name} is now bound to amq.fanout."
puts
puts "Deleting queue #{queue.name}"
queue.delete do |message_count|
puts "Deleted."
puts