activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravimbhatt <r...@qubitdigital.com>
Subject Re: QueueConnection Stop Waits forever: Stops Message Delivery to consumer
Date Thu, 21 Jul 2011 11:26:14 GMT
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-tp3569019p3683430.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message