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