changed basic.nack to basic.reject

basic.nack is RabbitMQ-only

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):

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):

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.
         """