5.5.1 ActiveMQ freezes, why ?

Oleg Dulin Tue, 11 Sep 2012 11:24:43 -0700

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 onjava.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">

                                               <!-- pendingQueuePolicy>
                                                       <fileQueueCursor />
                                               </pendingQueuePolicy -->
                                       </policyEntry>
                               </policyEntries>
                       </policyMap>
               </destinationPolicy>
…
<networkConnectors>
                       <networkConnector name="connector2.2"
                               uri="static:(tcp://.……:3000)" />
               </networkConnectors>


               <persistenceAdapter>

<kahaDBdirectory="${activemq.base}/activemq-data/kahadb" />

               </persistenceAdapter>


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

5.5.1 ActiveMQ freezes, why ?

Reply via email to