如何删除rabbitmq(pika)中的消息

问题描述 投票:0回答:1

如何删除发布和接收的消息,在rabbitmq我用python测试rabitmq,同样的消息继续发布和接收,如何避免这种情况。如何删除已发布和已接收的消息

python rabbitmq pika
1个回答
0
投票

请关注此:

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')
© www.soinside.com 2019 - 2024. All rights reserved.