我需要一个设置,多个消费者应该连续地监听一个队列。我能够启动多个消费者和处理工作,如预期。但是过了一段时间之后,当没有消息要处理时,消费者就会被以下异常消息自动杀死。No handlers could be found for logger "pika.adapters.base_connection"
是否可以设置侦听队列的进程可以连续运行的设置?waterfall/worker_waterfall.py", line 675, in <module>
Web App有一个监听器,多个生产者,多个WorkerBee。侦听器将消息从其队列推送到WorkerBee。生成的所有消息都在侦听器中排队。我想实现一个可以使用某种负载平衡进程将消息从侦听器队列发送到每个WorkerBee的进程。在侦听器队列或WorkerBee队列中只出现一个消息实例。
做这件事最好的方法是什么?如何将消息从监听器队列推送到WorkerBee队列</em