spec/amqp_spec.rb in em-synchrony-1.0.2 vs spec/amqp_spec.rb in em-synchrony-1.0.3
- old
+ new
@@ -81,10 +81,10 @@
q2.bind(ex)
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
end