只接收一次来自rabbitmq的消息，而不是连续接收
嗨,
我使用下面的代码来接收来自rabbitmq服务器的消息...
程序运行得很好，但在消费部分，我不需要连续消费，而是需要一个消息一个消息地消费。
选择 | 换行 | 行号
- import pika
- import os
- import time
- connection = pika.BlockingConnection(pika.ConnectionParameters(
- host='localhost'))
- channel = connection.channel()
- channel.exchange_declare(exchange='acknowledgment',type="direct",durable=True,auto_delete=False)
- channel.queue_declare(queue="ACK",durable=True)
- channel.queue_bind(queue='ACK',exchange='acknowledgment',routing_key='acknowledgment')
- def callback(ch, method, properties, body):
- srt="%r" % (body)
- print "Received"
- channel.basic_consume(callback,queue='ACK',no_ack=True,consumer_tag='acknowledgment')
- channel.start_consuming()
请指导应该为此修改什么类型的代码...
感谢并致以问候，
Robert.J