Blame SOURCES/qpid-transport-works-with-celery-4.patch
|
 |
b42c2a |
diff --git a/kombu/transport/qpid.py b/kombu/transport/qpid.py
|
|
|
b42c2a |
index 2204624..35da356 100644
|
|
|
b42c2a |
--- a/kombu/transport/qpid.py
|
|
|
b42c2a |
+++ b/kombu/transport/qpid.py
|
|
|
b42c2a |
@@ -850,7 +850,7 @@ def basic_get(self, queue, no_ack=False, **kwargs):
|
|
|
b42c2a |
except Empty:
|
|
|
b42c2a |
pass
|
|
|
b42c2a |
|
|
|
b42c2a |
- def basic_ack(self, delivery_tag):
|
|
|
b42c2a |
+ def basic_ack(self, delivery_tag, multiple=False):
|
|
|
b42c2a |
"""Acknowledge a message by delivery_tag.
|
|
|
b42c2a |
|
|
|
b42c2a |
Acknowledges a message referenced by delivery_tag. Messages can
|
|
|
b42c2a |
@@ -864,8 +864,12 @@ def basic_ack(self, delivery_tag):
|
|
|
b42c2a |
:param delivery_tag: The delivery tag associated with the message
|
|
|
b42c2a |
to be acknowledged.
|
|
|
b42c2a |
:type delivery_tag: uuid.UUID
|
|
|
b42c2a |
+ :param multiple: not implemented. If set to True an AssertionError
|
|
|
b42c2a |
+ is raised.
|
|
|
b42c2a |
+ :type multiple: bool
|
|
|
b42c2a |
|
|
|
b42c2a |
"""
|
|
|
b42c2a |
+ assert multiple is False
|
|
|
b42c2a |
self.qos.ack(delivery_tag)
|
|
|
b42c2a |
|
|
|
b42c2a |
def basic_reject(self, delivery_tag, requeue=False):
|