在pi的处理程序中调用process\u data_事件

2024-09-29 21:29:11 发布

您现在位置:Python中文网/ 问答频道 /正文

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引起的静默问题。在


Tags: 对象代码消息处理程序类型databasicchannel

热门问题