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

如何删除发布和接收的消息,在rabbitmq 我正在用python测试rabitmq,同样的消息还在继续发布和接收,如何避免这种情况。 我怎样才能删除公布并收到如何删除rabbitmq中的消息(pika)

回答:

请遵循这样的消息:

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

以上是 如何删除rabbitmq中的消息(pika) 的全部内容, 来源链接: utcz.com/qa/261957.html

回到顶部