Hi All,
I am on my way to write a POC, in which i am facing issues related to
threads.
I have ActiveMQ (V5.3.0) running on my remote Linux (RHEL) box and which can
be reached via tcp protocol and 62616 port.
Here is my usecase which i am trying to implement in the POC.
1.My JMS client is running outside of the ActiveMQ server and need to
register to the ActiveMQ topic.
2.The # of topics may goes beyond 3000+.
3.Need to achieve connection pooling/session pooling/thread pooling on my
camel consumer while consuming topic message.
Hence in my POC i am trying to create 500+ routes in a single route builder.
When i start my POC after some time, i am getting the following exception.
Exception in thread "main" java.lang.OutOfMemoryError: unable to create new
native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Unknown Source)
at
java.util.concurrent.ThreadPoolExecutor.addIfUnderMaximumPoolSize(Unknown
Source)
at java.util.concurrent.ThreadPoolExecutor.execute(Unknown Source)
at
org.springframework.jms.listener.DefaultMessageListenerContainer.doRescheduleTask(DefaultMessageListenerContainer.java:669)
at
org.springframework.jms.listener.AbstractJmsListeningContainer.resumePausedTasks(AbstractJmsListeningContainer.java:536)
at
org.springframework.jms.listener.AbstractJmsListeningContainer.doStart(AbstractJmsListeningContainer.java:285)
at
org.springframework.jms.listener.AbstractJmsListeningContainer.start(AbstractJmsListeningContainer.java:263)
at
org.springframework.jms.listener.DefaultMessageListenerContainer.start(DefaultMessageListenerContainer.java:555)
at
org.apache.camel.component.jms.JmsConsumer.startListenerContainer(JmsConsumer.java:79)
at
org.apache.camel.component.jms.JmsConsumer.doStart(JmsConsumer.java:121)
at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:67)
at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:54)
at
org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:60)
at
org.apache.camel.impl.DefaultCamelContext.startServices(DefaultCamelContext.java:1613)
at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:1888)
at
org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:1841)
at
org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:1767)
at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:1548)
at
org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1440)
at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1336)
at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:67)
at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:54)
at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1314)
at
com.cisco.pnp.camel.connection.issue.CamelConnectionIssue.<init>(CamelConnectionIssue.java:63)
at
com.cisco.pnp.camel.connection.issue.CamelConnectionIssue.main(CamelConnectionIssue.java:76)
Pls help on fix this issue.
And also i want to do connection pooling/session pooling and thread pooling
on my camel consumer as the no of topics which the client subscribes to MOM
is really huge.
http://camel.465427.n5.nabble.com/file/n5012594/CamelConnectionIssue.java
CamelConnectionIssue.java
http://camel.465427.n5.nabble.com/file/n5012594/SimpleBean.java
SimpleBean.java
http://camel.465427.n5.nabble.com/file/n5012594/RouteProducer.java
RouteProducer.java
--
View this message in context:
http://camel.465427.n5.nabble.com/Camle-ActiveMQ-connection-polling-and-threading-issue-tp5012594p5012594.html
Sent from the Camel - Users mailing list archive at Nabble.com.
