Используя клиент pika, я хочу отобразить все сообщения, находящиеся в очереди в данный момент, без их использования.Просто чтобы узнать, насколько занята очередь, и отобразить задания.
Пока я могу читать только одно сообщение по мере его поступления:
channel.queue_declare(queue='queue1', durable=True)
channel.basic_consume(on_message, queue='queue1')
channel.start_consuming()
def on_message(channel, method, properties, message):
channel.basic_ack(delivery_tag=method.delivery_tag)
print("Message: %s", message)
Как я могу прочитать всю очередь?