getActiveConsumerCount of DefaultMessageListenerContainer, возвращающий всегда 0 - PullRequest
Новая
       18

getActiveConsumerCount of DefaultMessageListenerContainer, возвращающий всегда 0

0 голосов
/ 28 августа 2018

Ниже приведен мой фрагмент кода. Я хочу увеличить количество потребителей при увеличении пропускной способности. Но getActiveConsumerCount всегда возвращает ноль. Независимо от того, сколько сообщений публикуется. Может кто-нибудь, пожалуйста, объясните мне это.? 

@Bean(name="msgListenerContainerIncoming")`enter code here`
public DefaultMessageListenerContainer msgListenerContainerInQueue()
{
    DefaultMessageListenerContainer msgListenerContainer = new DefaultMessageListenerContainer();
    msgListenerContainer.setConcurrency(this.appProperties.getProperty("mq.listner.concurrency"));
    msgListenerContainer.setMessageListener(mqGateway());
    msgListenerContainer.setConnectionFactory((ConnectionFactory) jndiObjFactoryBeanIncomingQueue().getObject());
    msgListenerContainer.setDestinationName(this.appProperties.getProperty("jms.jndi.destination.incoming"));
    msgListenerContainer.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
    msgListenerContainer.setTransactionManager(JmsTransactionManager(msgListenerContainer.getConnectionFactory()));
    logger.info(msgListenerContainer.getIdleConsumerLimit());
    logger.info(msgListenerContainer.getConcurrentConsumers());
    logger.info(msgListenerContainer.getActiveConsumerCount());
    msgListenerContainer.setDestinationResolver(destinationResolver());
    msgListenerContainer.setCacheLevel(msgListenerContainer.CACHE_NONE);
    msgListenerContainer.afterPropertiesSet();       
    return msgListenerContainer;
}
...