From 67c8b5d35fec5ba2a1f8b05148008dea046bb060 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Fri, 24 Jun 2016 16:04:45 +0200
Subject: [PATCH] bugfix
---
coolamqp/handler.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/coolamqp/handler.py b/coolamqp/handler.py
index e92b17b..fb6613e 100644
--- a/coolamqp/handler.py
+++ b/coolamqp/handler.py
@@ -216,6 +216,6 @@ class ClusterHandlerThread(threading.Thread):
:param receivedMessage: a ReceivedMessage object to ack
:param on_completed: callable/0 to call when acknowledgemenet succeeded
"""
- self.order_queue.put(NAcknowledgeMessage(receivedMessage.connect_id,
+ self.order_queue.append(NAcknowledgeMessage(receivedMessage.connect_id,
receivedMessage.delivery_tag,
on_completed=on_completed))
--
GitLab