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