How to configure concurrentConsumer for Camel InOut JmsProducer ?
Issue
- How to configure concurrentConsumer for Camel InOut JmsProducer ?
- Why the whole application freezes, when applied more than
200 consumers? Is it because of an extra modification needed? - Using camel route user read from
amqbut every time theJmsConsumerthread pool replies with the same thread. How to to configureAMQso that it uses every time a different thread to dispatch the messages. User have used the configurationUseDedicatedTaskRunner=falseandoptimizedDispatch=truebut everytime user was printing out the thread's name and was getting for example thread #18 ofJmsConsumerthread pool. - How to achieve the
multithreadeddispatching of messages fromamqcomponent? - After adding the below configuration, got the different thread name of the JmsConsumer. Is it a correct approach?
ACTIVEMQCONFIGURATION.setBrokerURL( brokerURL );
ACTIVEMQCONFIGURATION.setUserName( FUSEPROPS.getCon_ActiveMQ_User() );
ACTIVEMQCONFIGURATION.setPassword( FUSEPROPS.getCon_ActiveMQ_Pass() );
ACTIVEMQCONFIGURATION.setUsePooledConnection( true );
ACTIVEMQCONFIGURATION.setUseSingleConnection( false );
ACTIVEMQCONFIGURATION.setAutoStartup( true );
ACTIVEMQCONFIGURATION.setConcurrentConsumers(200);
from( TCPSERVER.getEndPoint() ).routeId( CLASSNAME ).routePolicy( POLICY ).startupOrder(100)
.setExchangePattern(ExchangePattern.InOut)
.process(new DebuggingProcessor())
.to( ExchangePattern.OutOnly, ACTIVEMQENDPOINT.getEndPoint( "aQ" ) )
.process(new TcpServerSyncResponseProcessor() );
Environment
- Red Hat JBoss Fuse
- 6.2.0
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.