Hi,
I have an application which feeds data based on customers request.
Data Engine -----> Active MQ --------> MV Engine ---------- Customers
subscribe / unsubscribe to MV Engine using socket & request for data.
We used 4.0 before. We wanted to upgrade to 4.1.1. We did the same tests &
got the same results.
Whenever the MV Engine was unable to unsubscribe or subscribe & receive
data, I took thread dumps of active mq. I saw the following:
"ActiveMQ Scheduler" daemon prio=1 tid=0x084c0978 nid=0x3cd1 in
Object.wait() [0x62571000..0x62572030]
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:432)
at
edu.emory.mathcs.backport.java.util.concurrent.TimeUnit.timedWait(TimeUnit.java:301)
at
edu.emory.mathcs.backport.java.util.concurrent.DelayQueue.take(DelayQueue.java:156)
- locked <0x8ee070a0> (a java.lang.Object)
at
edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:590)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:477)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:674)
at java.lang.Thread.run(Thread.java:595)
"ActiveMQ Scheduler" daemon prio=1 tid=0x08848770 nid=0x3cd0 in
Object.wait() [0x67497000..0x67497fb0]
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:432)
at
edu.emory.mathcs.backport.java.util.concurrent.TimeUnit.timedWait(TimeUnit.java:301)
at
edu.emory.mathcs.backport.java.util.concurrent.DelayQueue.take(DelayQueue.java:156)
- locked <0x8ee070a0> (a java.lang.Object)
at
edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:590)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:477)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:674)
at java.lang.Thread.run(Thread.java:595)
"ActiveMQ Transport: tcp://localhost/127.0.0.1:2506" prio=1 tid=0x6385fdb0
nid=0x3ccb runnable [0x66477000..0x66477f30]
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.read(SocketInputStream.java:129)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:49)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:56)
at java.io.DataInputStream.readInt(DataInputStream.java:353)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
at java.lang.Thread.run(Thread.java:595)
I am just wondering if something in active mq hangs not allowing my
application thread to receive data or do further events.
Please advice.
Thanks
Badri
--
View this message in context:
http://www.nabble.com/Active-MQ-hangs-tf4535997s2354.html#a12945639
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
