diff --git a/coolamqp/backends/base.py b/coolamqp/backends/base.py index fd7b2dc0556b3012fe04500c2a1cc4dd0fd96bdd..a86e1ca68b27daec64178c678ea7368b704214b3 100644 --- a/coolamqp/backends/base.py +++ b/coolamqp/backends/base.py @@ -102,10 +102,10 @@ class AMQPBackend(object): :param prefetch_count: prefetch window in terms of whole messages """ - def basic_nack(self, delivery_tag): + def basic_reject(self, delivery_tag): """ - NACK a message. - :param delivery_tag: delivery tag to nack + Reject a message + :param delivery_tag: delivery tag to reject """ def basic_publish(self, message, exchange, routing_key): diff --git a/coolamqp/backends/pyamqp.py b/coolamqp/backends/pyamqp.py index 4ed88094c968f3f4ca8cfb8c16e9d7b91caf226a..8f50e2d7c437626c177e41b6bc7df3eb4c30416c 100644 --- a/coolamqp/backends/pyamqp.py +++ b/coolamqp/backends/pyamqp.py @@ -93,8 +93,8 @@ class PyAMQPBackend(AMQPBackend): self.channel.queue_delete(queue.name) @translate_exceptions - def basic_nack(self, delivery_tag): - self.channel.basic_nack(delivery_tag, multiple=False) + def basic_reject(self, delivery_tag): + self.channel.basic_reject(delivery_tag, True) @translate_exceptions def queue_declare(self, queue): diff --git a/coolamqp/messages.py b/coolamqp/messages.py index 7dd218fb1dbba3aa09862b40fc55bab3c9becb4b..4f05f59444a6e6aace3fcd3d341485b8a00faaf5 100644 --- a/coolamqp/messages.py +++ b/coolamqp/messages.py @@ -42,6 +42,9 @@ class ReceivedMessage(Message): def nack(self, on_completed=None): """ Negative-acknowledge this message to the broker. + + This internally results in a basic.reject + :param on_completed: callable/0 to call on acknowledged. Callable will be executed in ClusterHandlerThread's context. """