diff --git a/aioamqp/channel.py b/aioamqp/channel.py index 8b39fb2..ee32916 100644 --- a/aioamqp/channel.py +++ b/aioamqp/channel.py @@ -790,7 +790,7 @@ def publish(self, payload, exchange_name, routing_key, properties=None, mandator assert payload, "Payload cannot be empty" if self.publisher_confirms: - delivery_tag = next(self.delivery_tag_iter) + delivery_tag = next(self.delivery_tag_iter) # pylint: disable=stop-iteration-return fut = self._set_waiter('basic_server_ack_{}'.format(delivery_tag)) method_frame = amqp_frame.AmqpRequest(