How to configure concurrentConsumer for Camel InOut JmsProducer ?

Solution Verified - Updated -

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 amq but every time the JmsConsumer thread pool replies with the same thread. How to to configure AMQ so that it uses every time a different thread to dispatch the messages. User have used the configuration UseDedicatedTaskRunner=false and optimizedDispatch=true but everytime user was printing out the thread's name and was getting for example thread #18 of JmsConsumer thread pool.
  • How to achieve the multithreaded dispatching of messages from amq component?
  • 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.

Current Customers and Partners

Log in for full access

Log In
Close

Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.