Permalink
Browse files

Added an ack() in RabbitMQSubscriber to remove the message from the q…

…ueue
  • Loading branch information...
1 parent 4da3e82 commit 5b51d7e7372ad30fa2f9a24c775f9c65d0a20c64 @vals vals committed Oct 10, 2012
Showing with 4 additions and 1 deletion.
  1. +4 −1 logbook/queues.py
View
@@ -233,7 +233,10 @@ def recv(self, timeout=None):
else:
rv = self.queue.get(timeout=timeout)
- return LogRecord.from_dict(rv.payload)
+ log_record = rv.payload
+ rv.ack()
+
+ return LogRecord.from_dict(log_record)
class ZeroMQSubscriber(SubscriberBase):

0 comments on commit 5b51d7e

Please sign in to comment.