Re: QueueConnection Stop Waits forever: Stops Message Delivery to consumer

[ravimbhatt <ra...@qubitdigital.com>]

Hi,

I was on vacation fro a while. 

Here is a thread dump...for the waiting thread. 


Name: ActiveMQ Session Task
State: WAITING on org.apache.activemq.thread.PooledTaskRunner$1@35e59bda
Total blocked: 3  Total waited: 4

Stack trace: 
java.lang.Object.wait(Native Method)
org.apache.activemq.thread.PooledTaskRunner.shutdown(PooledTaskRunner.java:95)
org.apache.activemq.thread.PooledTaskRunner.shutdown(PooledTaskRunner.java:102)
org.apache.activemq.ActiveMQSessionExecutor.stop(ActiveMQSessionExecutor.java:155)
   - locked org.apache.activemq.ActiveMQSessionExecutor@55f6bd6a
org.apache.activemq.ActiveMQSession.stop(ActiveMQSession.java:1653)
org.apache.activemq.ActiveMQConnection.stop(ActiveMQConnection.java:550)
   - locked java.util.concurrent.CopyOnWriteArrayList@561d0c91
com.qubit.command.DefaultQueueListenerCommand.stopConsumption(DefaultQueueListenerCommand.java:239)
com.qubit.command.DefaultQueueListenerCommand.onMessage(DefaultQueueListenerCommand.java:173)
   - locked com.qubit.command.UrlCategorisationReqConsumerCmd@fed453
org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1229)
   - locked java.lang.Object@37cd238a
org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:134)
org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:205)
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
java.lang.Thread.run(Thread.java:662)


And here is one other thread thats blocked for the same object..


Name: Thread-23
State: BLOCKED on com.qubit.command.UrlCategorisationReqConsumerCmd@fed453
owned by: ActiveMQ Session Task
Total blocked: 1,961  Total waited: 84,130

Stack trace: 
com.qubit.command.DefaultQueueListenerCommand.update(DefaultQueueListenerCommand.java:215)
com.qubit.categoriser.URLCategoriser.notifyObservers(URLCategoriser.java:263)
com.qubit.categoriser.URLCategoriser.categorise(URLCategoriser.java:194)
com.qubit.categoriser.URLCategoriser.run(URLCategoriser.java:270)
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
java.lang.Thread.run(Thread.java:662)


--
View this message in context: http://activemq.2283324.n4.nabble.com/QueueConnection-Stop-Waits-forever-Stops-Message-Delivery-to-consumer-tp3569019p3683421.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.