activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Badri <badrinarayanan.doraisw...@fxall.com>
Subject Active MQ hangs
Date Fri, 28 Sep 2007 18:04:33 GMT

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.


Mime
View raw message