Pika：如何从回调函数中获取 return 值？

Question

我的程序中有一个回调函数需要检查 success/failure。我怎样才能做到这一点？在我下面的示例中，failure_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()

Answer 1

所有内容 link：https://www.rabbitmq.com/tutorials/tutorial-six-python.html

我们创建一个 class 用于调用请求，然后等待响应 ID 等于之前发送的 correlation_id。

Pika：如何从回调函数中获取 return 值？

Pika: How to get a return value from a callback function?

rabbitmq

pika