[ https://issues.apache.org/jira/browse/AMQ-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137382#comment-15137382 ]
Tim Kieschnick commented on AMQ-5297: ------------------------------------- Was this ever resolved or worked around? > PooledSession with lots of consumers can fail to start fully > ------------------------------------------------------------ > > Key: AMQ-5297 > URL: https://issues.apache.org/jira/browse/AMQ-5297 > Project: ActiveMQ > Issue Type: Bug > Components: activemq-pool, JMS client > Affects Versions: 5.8.0 > Environment: java version "1.7.0_51" > Java(TM) SE Runtime Environment (build 1.7.0_51-b13) > Java HotSpot(TM) 64-Bit Server VM (build 24.51-b03, mixed mode) > Reporter: Sam hendley > > We have a case where we are trying to startup 100s of camel routes and it > appears to be causing an issue where the consumer is only partially started > and the thread is stuck waiting for for the consumer to be fully created. The > consumer appears to be created on the broker side so that it is getting > messages enqueued and dispatched, just never serviced. > Could this be due to our connection pool being too small? Could we avoid this > problem with asyncSend? > {quote} > "Camel (AppsJVM) thread #28 - JmsConsumer[response.queue]" - Thread t@318 > java.lang.Thread.State: WAITING > at sun.misc.Unsafe.park(Native Method) > - parking to wait for <ee029ee> (a > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) > at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) > at > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) > at > java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) > at > org.apache.activemq.transport.FutureResponse.getResult(FutureResponse.java:40) > at > org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:87) > at > org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1380) > at > org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1912) > at > org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:273) > at > org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1144) > at > org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1088) > at > org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1001) > at > org.apache.activemq.pool.PooledSession.createConsumer(PooledSession.java:311) > at > org.springframework.jms.listener.AbstractPollingMessageListenerContainer.createConsumer(AbstractPollingMessageListenerContainer.java:503) > at > org.springframework.jms.listener.AbstractPollingMessageListenerContainer.createListenerConsumer(AbstractPollingMessageListenerContainer.java:224) > at > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1094) > at > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1070) > at > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1063) > at > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:960) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > Locked ownable synchronizers: > - locked <4deb7015> (a java.util.concurrent.ThreadPoolExecutor$Worker) > {quote} > {quote} > <bean id="JMSPooledConnectionFactory" > class="org.apache.activemq.pool.PooledConnectionFactory"> > <property name="maxConnections" value="8" /> > <property name="maximumActiveSessionPerConnection" value="500" /> > <property name="idleTimeout" value="0" /> > <property name="connectionFactory" ref="JMSConnectionFactory" /> > </bean> > {quote} -- This message was sent by Atlassian JIRA (v6.3.4#6332)