Permalink
Browse files

Whops, I forgot {:ack => true}.

  • Loading branch information...
botanicus committed May 18, 2011
1 parent 01af1f7 commit 76cb038071e6f89195cb3e6a1c3c0474b8046731
Showing with 1 addition and 1 deletion.
  1. +1 −1 ruby/worker.rb
View
@@ -16,7 +16,7 @@
puts " [*] Waiting for messages. To exit press CTRL+C"
channel.prefetch(1)
- queue.subscribe do |header, body|
+ queue.subscribe(:ack => true) do |header, body|
puts " [x] Received #{body}"
EM.add_timer(body.count(".")) do
puts " [x] Done"

0 comments on commit 76cb038

Please sign in to comment.