在spring的xml配置中,我有以下配置。
<rabbit:listener-container id="testListenerContainer" connection-factory="connectionFactory" prefetch="1" concurrency="10">
<rabbit:listener ref="testListener" queues="${testInputQueueName}" />
</rabbit:listener-container>如果我想降低并发性,是否可以手动更改并发性,让spring重新加载配置以减少并发性?如果可能的话,怎么做呢?
发布于 2014-12-07 15:26:37
是的,你可以在运行时做到这一点。见SimpleMessageListenerContainer setConcurrentConsumers和setMaxConcurrentConsumers。是的,SimpleMessageListenerContainer改变了它围绕一组正在运行的BlockingQueueConsumer的内部状态。
只有您需要该SimpleMessageListenerContainer的SimpleMessageListenerContainer才能将其注入到您的控制服务。在您的例子中,它是testListenerContainer。
https://stackoverflow.com/questions/27343043
复制相似问题