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, tools, and much more.

Current Customers and Partners

Log in for full access

Log In

New to Red Hat?

Learn more about Red Hat subscriptions

Using a Red Hat product through a public cloud?

How to access this content