例如,我有一个
consumer
和一个 producer
。
在生产者中,我为消费者发布一些数据。
在消费者中,我做了一些事情,我可以确认或拒绝请求。
如何在
producer.py
中找到我的请求得到 basic_ack
或 basic_reject
。
我找不到任何方法来对生产者中的拒绝做一些事情。
有人知道我怎样才能在
producer
、basic_ack
、basic_nack
或basic_reject
上做一些事情吗?
你不能。这不仅限于皮卡,还包括排队系统的工作原理。您的消费者必须将消息发送回 RabbitMQ,然后生产者会收到该消息。