2017-12-18 344 views
0

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

+0

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

+0

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

+0

你可以將'''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 –

回答

0

請遵循這樣的消息:

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