This seems to be related to the 2000 limit on the linkedblockingqueue 
inside of VMTransport…

Where is this configured ?



On 2012-09-11 18:23:56 +0000, Oleg Dulin said:

> Here is the stack trace:
> 
> One thread:
> 
> Name: LS:IndexItemQueue:2
> State: BLOCKED on java.lang.Object@699b7e6 owned by: LS:IndexItemQueue:8
> Total blocked: 42,886  Total waited: 27,663
> 
> Stack trace:
>  org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1698)
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:231) 
> 
> org.apache.activemq.ActiveMQMessageProducerSupport.send(ActiveMQMessageProducerSupport.java:241) 
> 
> 
> The other thread:
> 
> ame: LS:IndexItemQueue:8
> State: WAITING on 
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@55f8606c 
> 
> Total blocked: 32,969  Total waited: 20,914
> 
> Stack trace:
>  sun.misc.Unsafe.park(Native Method)
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1987) 
> 
> java.util.concurrent.LinkedBlockingQueue.put(LinkedBlockingQueue.java:306)
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:94)
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
>    - locked java.lang.Object@6e0f1ea9
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60) 
> 
> org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1265) 
> 
> 
> 
> Here is my config:
> 
>         <broker xmlns="http://activemq.apache.org/schema/core"
>                 brokerName="localhost" dataDirectory="./activemq-data"
>                 destroyApplicationContextOnStop="true" 
> persistent="true" useJmx="true">
> ...
>                <destinationPolicy>
>                         <policyMap>
>                                 <policyEntries>
>                                         <policyEntry topic=">" 
> producerFlowControl="false"
>                                                 memoryLimit="512mb">
>                                                 <!-- pendingSubscriberPolicy>
>                                                         <fileCursor />
>                                                 </pendingSubscriberPolicy -->
>                                         </policyEntry>
>                                         <policyEntry queue=">" 
> producerFlowControl="false"
>                                                 memoryLimit="512mb">
>                                                 <!-- Use VM cursor for 
> better latency For more information, see: 
> http://activemq.apache.org/message-cursors.html -->
>                                                 <!-- pendingQueuePolicy>
>                                                         <fileQueueCursor />
>                                                 </pendingQueuePolicy -->
>                                         </policyEntry>
>                                 </policyEntries>
>                         </policyMap>
>                 </destinationPolicy>
> …
>  <networkConnectors>
>                         <networkConnector name="connector2.2"
>                                 uri="static:(tcp://.……:3000)" />
>                 </networkConnectors>
> 
> 
>                 <persistenceAdapter>
>                         <kahaDB 
> directory="${activemq.base}/activemq-data/kahadb" />
>                 </persistenceAdapter>
> 
> 
> Any ideas ?


-- 
Regards,
Oleg Dulin
NYC Java Big Data Engineer
http://www.olegdulin.com/