如何刪除rabbitmq中的消息（pika）

如何刪除發佈和接收的消息，在rabbitmq 我正在用python測試rabitmq，同樣的消息還在繼續發佈和接收，如何避免這種情況。我怎樣才能刪除公佈並收到如何刪除rabbitmq中的消息（pika）

2017-12-18 user3640571

你必須發送確認返回其中收到並設置的消息是自動刪除選項，或者在接收到確認消息時執行自定義代碼以刪除消息。 –

是否可以在rabbitmq的配置中設置它 – user3640571

你可以將'''task_id.revoke（termination = True）'''設置爲params。或清除所有任務https://stackoverflow.com/questions/24899772/how-do-i-permanently-remove-a-celery-task-from-rabbitmq?answertab=active#tab-top –

請遵循這樣的消息：

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

最幸運的你是不是發送ACK：

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')

來源

2017-12-18 13:16:40 Gabriele

如何刪除rabbitmq中的消息（pika）

回答

相關問題