RabbitMQ 有一种单一主动消费者模式,其中多个连接的侦听器中只有一个从队列中获取消息
一次只有一个消费者从队列中消费,并故障转移到另一个注册消费者,以防活动消费者被取消或死亡
有没有办法通过camel 4.4的
from
以前,传递
&exclusiveConsumer=true
SpringRabbitMQComponent
要激活,您可以使用
arg.consumer.x-single-active-consumer=true
在队列的定义中。 github上的源代码,带有
getConsumerArgs