pika是否支持以下类型的代码?我在处理程序中获取connection对象,创建一个新通道,并通过在连接上调用process_data_events
来进行一些消息处理。因此,当所有这些发生时,导致被调用处理程序的对process_data_events
的调用尚未返回。在
def handler(channel, method, props, msg):
connection = channel.connection
channel2 = connection.channel()
channel2.basic_consume(queue2, handler2)
channel2.basic_publish(exchange, routing_key, message)
while some_condition:
connection.process_data_events()
channel.basic_consume(queue1, handler)
channel.start_consuming()
它似乎可以工作,但我想确保没有任何由递归调用process_data_events
引起的静默问题。在
目前没有回答
相关问题 更多 >
编程相关推荐