Use :manual_ack as a more descriptive name
This commit is contained in:
parent
07d1108c56
commit
4a55836e46
@ -13,7 +13,7 @@ ch.prefetch(1)
|
||||
puts " [*] Waiting for messages. To exit press CTRL+C"
|
||||
|
||||
begin
|
||||
q.subscribe(:ack => true, :block => true) do |delivery_info, properties, body|
|
||||
q.subscribe(:manual_ack => true, :block => true) do |delivery_info, properties, body|
|
||||
puts " [x] Received '#{body}'"
|
||||
# imitate some work
|
||||
sleep 1.0
|
||||
|
Loading…
Reference in New Issue
Block a user