diff --git a/coolamqp/handler.py b/coolamqp/handler.py index e92b17b966d5f759f1a7792e1747146a0f78e52c..fb6613e0aca4f0ba21acc56c9f6d0e557a98179b 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))