Commit `b0d95a0`

mo khan <mo@mokhan.ca>

2014-10-10 16:23:28

use manual ack to ensure a message is handled properly or else re-scheduled to another worker.

main

1 parent e5d5b6e

Changed files (1)

lib

example2

receive.rb

@@ -10,7 +10,7 @@ channel = connection.create_channel
 queue = channel.queue("hello")
 
 puts " [*] Waiting for messages in #{queue.name}. To exit press CTRL+C"
-queue.subscribe(ack: true, block: true) do |delivery_info, properties, body|
+queue.subscribe(manual_ack: true, block: true) do |delivery_info, properties, body|
   puts " [x] Received #{body}"
   sleep body.count(".").to_i
   puts " [x] Done"

Commit b0d95a0

Commit `b0d95a0`