You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Timothy Bish (JIRA)" <ji...@apache.org> on 2015/03/19 18:11:38 UTC

[jira] [Commented] (AMQ-5675) org.apache.activemq.leveldb.CountDownFuture

    [ https://issues.apache.org/jira/browse/AMQ-5675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369725#comment-14369725 ] 

Timothy Bish commented on AMQ-5675:
-----------------------------------

Have you tested this on a newer version like 5.11.1 ?

> org.apache.activemq.leveldb.CountDownFuture
> -------------------------------------------
>
>                 Key: AMQ-5675
>                 URL: https://issues.apache.org/jira/browse/AMQ-5675
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: activemq-leveldb-store
>    Affects Versions: 5.9.1
>         Environment: activemq 5.9.1 
> lelveldb 
> zookeeper
>            Reporter: gbsnaker
>            Priority: Critical
>
> hi 
>    lots of threads blocked and tracer by id  5429 thread. 
>    here is stack . 
>    
> zookeeper-3.4.5
> activemq 5.9.1
> leveldb-1.15.0 
> Thread ID: 4329
> Thread Name: ActiveMQ Transport: tcp:///172.24.139.37:55455@61616
> Waited Count: 1 Waited Time: 1704727ms
> Blocked Count: 0 Blocked Time: 0ms
> Lock Name: java.util.concurrent.CountDownLatch$Sync@198e6601 Lock Class Name: java.util.concurrent.CountDownLatch$Sync Lock Identity Hash Code: 428762625
> Locked Monitors
>         Frame: 10 org.apache.activemq.broker.region.Topic .doMessageSend  (Topic.java)
> Stack Trace
>         sun.misc.Unsafe . park  (Unsafe.java) (Native)
>         java.util.concurrent.locks.LockSupport . park  (LockSupport.java:156)
>         java.util.concurrent.locks.AbstractQueuedSynchronizer . parkAndCheckInterrupt  (AbstractQueuedSynchronizer.java:811)
>         java.util.concurrent.locks.AbstractQueuedSynchronizer . doAcquireSharedInterruptibly  (AbstractQueuedSynchronizer.java:969)
>         java.util.concurrent.locks.AbstractQueuedSynchronizer . acquireSharedInterruptibly  (AbstractQueuedSynchronizer.java:1281)
>         java.util.concurrent.CountDownLatch . await  (CountDownLatch.java:207)
>         org.apache.activemq.leveldb.CountDownFuture . get  (DBManager.scala:125)
>         org.apache.activemq.leveldb.LevelDBStore$ . waitOn  (LevelDBStore.scala:68)
>         org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore . addMessage  (LevelDBStore.scala:701)
>         org.apache.activemq.store.AbstractMessageStore . asyncAddTopicMessage  (AbstractMessageStore.java:105)
>         org.apache.activemq.broker.region.Topic . doMessageSend  (Topic.java:477)
>         org.apache.activemq.broker.region.Topic . send  (Topic.java:441)
>         org.apache.activemq.broker.region.AbstractRegion . send  (AbstractRegion.java:395)
>         org.apache.activemq.broker.region.RegionBroker . send  (RegionBroker.java:441)
>         org.apache.activemq.broker.jmx.ManagedRegionBroker . send  (ManagedRegionBroker.java:297)
>         org.apache.activemq.broker.BrokerFilter . send  (BrokerFilter.java:147)
>         org.apache.activemq.broker.CompositeDestinationBroker . send  (CompositeDestinationBroker.java:96)
>         org.apache.activemq.broker.TransactionBroker . send  (TransactionBroker.java:307)
>         org.apache.activemq.broker.MutableBrokerFilter . send  (MutableBrokerFilter.java:152)
>         org.apache.activemq.broker.TransportConnection . processMessage  (TransportConnection.java:493)
>         org.apache.activemq.command.ActiveMQMessage . visit  (ActiveMQMessage.java:756)
>         org.apache.activemq.broker.TransportConnection . service  (TransportConnection.java:291)
>         org.apache.activemq.broker.TransportConnection$1 . onCommand  (TransportConnection.java:145)
>         org.apache.activemq.transport.MutexTransport . onCommand  (MutexTransport.java:50)
>         org.apache.activemq.transport.WireFormatNegotiator . onCommand  (WireFormatNegotiator.java:113)
>         org.apache.activemq.transport.AbstractInactivityMonitor . onCommand  (AbstractInactivityMonitor.java:270)
>         org.apache.activemq.transport.TransportSupport . doConsume  (TransportSupport.java:83)
>         org.apache.activemq.transport.tcp.TcpTransport . doRun  (TcpTransport.java:214)
>         org.apache.activemq.transport.tcp.TcpTransport . run  (TcpTransport.java:196)
>         java.lang.Thread . run  (Thread.java:662) 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)