Permalink
Browse files

Added option parameter to one Queue#subscribe call in AMQP spec.

  • Loading branch information...
1 parent 6239e03 commit 5d125b91b91000d059902c2cdea44b1284dd2f91 @poffe poffe committed Oct 29, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 spec/amqp_spec.rb
View
@@ -83,7 +83,7 @@
nb_q1, nb_q2 = 0, 0
stop_cb = proc { EM.stop if nb_q1 + nb_q2 == 2 * nb_msg }
- q1.subscribe do |meta, msg|
+ q1.subscribe(:ack => false) do |meta, msg|
msg.should match(/^Bonjour [0-9]+/)
nb_q1 += 1
stop_cb.call

0 comments on commit 5d125b9

Please sign in to comment.