def acknowledge(self, method):
if method:
try:
self._channel.basic_ack(method.delivery_tag)
except pika.exceptions.AMQPError as e:
raise PipelineQueueError("Couldn't acknowledge message: {reason}".format(reason=e))
评论列表
文章目录