|
@ -72,7 +72,8 @@ public class StartListener {
|
|
|
listenerContainer.setMessageListener(receiver);
|
|
|
// 设置消费者集群数
|
|
|
int consumers = count;
|
|
|
listenerContainer.setConcurrentConsumers(consumers);
|
|
|
listenerContainer.setConcurrentConsumers(2);
|
|
|
listenerContainer.setMaxConcurrentConsumers(consumers);
|
|
|
// 设置监听队列还是主题 默认是队列
|
|
|
listenerContainer.setPubSubNoLocal(false);
|
|
|
// listenerContainer.setAcceptMessagesWhileStopping(true);
|