Pika: 如何从回调函数中获取返回值?

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

我的程序中有一个回调函数,我需要检查successfailure。在我下面的例子中,failail_code在哪里?我的片段。

def mq_callback(job_id, ch, method, body):
  # Do some stuff. But if the stuff fails...
   return failure_code

channel.basic_consume(
        queue='some queue',
        on_message_callback=lambda ch, method, properties, body: mq_callback(job_id, ch, method, body),
        auto_ack=False
    )

channel.start_consuming()
rabbitmq pika
1个回答
© www.soinside.com 2019 - 2024. All rights reserved.