Как удалить сообщение в rabbitmq с помощью pika?

Как удалить опубликованное и полученное сообщение в очереди rabbitmq. Я тестирую rabbitmq с python, используя pika.

Как я могу удалить сообщение, которое опубликовано и получено?


python rabbitmq pika
person user3640571    schedule 18.12.2017    source источник
comment
Вы должны отправить подтверждение того, какое сообщение вы получили, и установить опцию автоматического удаления true или ввести свой собственный код для удаления сообщения при получении подтверждения.   -  person DHARMENDRA SINGH    schedule 18.12.2017
comment
можно ли установить его в конфигурации rabbitmq   -  person user3640571    schedule 18.12.2017
comment
Вы можете сделать task_id.revoke(termination=True) в качестве параметров. или очистить все задачи stackoverflow.com/questions/24899772/   -  person Manoj Jadhav    schedule 18.12.2017

Ответы (1)


arrow_upward
0
arrow_downward

Пожалуйста, следуйте этому:

https://www.rabbitmq.com/tutorials/tutorial-two-python.html

вам повезло, что вы не отправляете подтверждение:

def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)
    time.sleep( body.count('.') )
    print " [x] Done"
    ch.basic_ack(delivery_tag = method.delivery_tag) ### <--- this one

channel.basic_consume(callback,
                      queue='hello')
person Gabriele Santomaggio    schedule 18.12.2017