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.
