From f7d4cd45fa7e8262b4c8210759f808e99d09a71d 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 12:29:15 +0200
Subject: [PATCH] changed basic.nack to basic.reject
basic.nack is RabbitMQ-only
---
coolamqp/backends/base.py | 6 +++---
coolamqp/backends/pyamqp.py | 4 ++--
coolamqp/messages.py | 3 +++
3 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/coolamqp/backends/base.py b/coolamqp/backends/base.py
index fd7b2dc..a86e1ca 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 4ed8809..8f50e2d 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 7dd218f..4f05f59 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.
"""
--
GitLab