RabbitMQ 取消回调 Pika Python

问题描述

我有一个消费者队列

channel.basic_consume(queue=queue_name,on_message_callback=callback_cluster,auto_ack=False)

我希望能够在收到取消消息时中断此回调。 目前我设置了另一个队列并监听这个。

channel.basic_consume(queue=cancel_queue_name,on_message_callback=cancel_cluster,auto_ack=False)

但是这显然不起作用，因为我使用了 BlockingConnection，那我该怎么办？

我尝试过的：

我尝试在 callback_cluster 中创建一个线程，但是在 Python 中终止这个线程并不容易。

我也尝试过使用多处理，但这给了我酸洗错误。

在鼠兔中是否有内置的方法来做到这一点？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）