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 of over 48,000 articles and solutions.
Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.
