rabbitmq - Pika：如何从回调函数中获取返回值？

Question

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

标签： rabbitmqpika

Answer 1

所有在这个链接：https ://www.rabbitmq.com/tutorials/tutorial-six-python.html

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