何时使用container.setStartConsumerMinInterval(3000)rabbit mq春季启动



我是spring-boot amqp库的新手,在搜索解决方案时,我会浏览这个属性。有人能解释这个属性的用途吗

.createListenerContainer();
container.setStartConsumerMinInterval(3000); ```

请参阅文档

https://docs.spring.io/spring-amqp/docs/current/reference/html/#startConsumerMinInterval

每个新消费者按需启动之前必须经过的时间(以毫秒为单位(。请参见侦听器并发。默认值:10000(10秒(。

https://docs.spring.io/spring-amqp/docs/current/reference/html/#listener-并发

默认情况下,侦听器容器启动一个从队列接收消息的使用者。

在检查上一节中的表时,您可以看到许多控制并发的属性。最简单的是concurrentConsumers,它创建了(固定(数量的同时处理消息的消费者。

。。。

此外,还添加了一个名为maxConcurrentConsumers的新属性,容器会根据工作负载动态调整并发性。这与四个附加属性配合使用:consecutiveActiveTriggerstartConsumerMinIntervalconsecutiveIdleTriggerstopConsumerMinInterval

最新更新