activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Márcio Moraes" <mmoraes...@gmail.com>
Subject Re: Please help check ActiveMQ 5.0.0 RC1
Date Thu, 27 Sep 2007 22:06:23 GMT
I ran again using journal persistence with derbyds and client hangs in other
point.

I am doing a simple request/reply message with temporary topic using in
consumer the ResourceAdapter and client jencks-amqpool

The new stack trace is:

[WARN ][ActiveMQ Scheduler]2007-09-27 19:03:36,998 FailoverTransport:236  -
Transport failed, attempting to automatically reconnect due to:
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too long.
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too long.
    at org.apache.activemq.transport.InactivityMonitor.readCheck(
InactivityMonitor.java:100)
    at org.apache.activemq.transport.InactivityMonitor$1.run(
InactivityMonitor.java:50)
    at org.apache.activemq.thread.Scheduler$SchedulerTimerTask.run(
Scheduler.java:36)
    at java.util.TimerThread.mainLoop(Timer.java:512)
    at java.util.TimerThread.run(Timer.java:462)
Full thread dump Java HotSpot(TM) Client VM (1.5.0_12-b04 mixed mode,
sharing):

"ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
tid=0x081980d0 nid=0x7277 runnable [0xafb47000..0xafb47fb0]
    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:50)
    at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
TcpBufferedInputStream.java:58)
    at java.io.DataInputStream.readInt(DataInputStream.java:353)
    at org.apache.activemq.openwire.OpenWireFormat.unmarshal(
OpenWireFormat.java:268)
    at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
TcpTransport.java:196)
    at org.apache.activemq.transport.tcp.TcpTransport.doRun(
TcpTransport.java:188)
    at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java
:176)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Session Task" daemon prio=1 tid=0x0834afd8 nid=0x7229 waiting on
condition [0xafbc8000..0xafbc8f30]
    at sun.misc.Unsafe.park(Native Method)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(
AbstractQueuedSynchronizer.java:716)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
(AbstractQueuedSynchronizer.java:771)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(
AbstractQueuedSynchronizer.java:1099)
    at java.util.concurrent.SynchronousQueue$Node.waitForPut(
SynchronousQueue.java:265)
    at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java:400)
    at java.util.concurrent.ThreadPoolExecutor.getTask(
ThreadPoolExecutor.java:470)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(
ThreadPoolExecutor.java:674)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Scheduler" daemon prio=1 tid=0x08835978 nid=0x7228 in Object.wait()
[0xafc49000..0xafc49eb0]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88f4ffe8> (a java.util.TaskQueue)
    at java.util.TimerThread.mainLoop(Timer.java:509)
    - locked <0x88f4ffe8> (a java.util.TaskQueue)
    at java.util.TimerThread.run(Timer.java:462)

"ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
tid=0x088352e0 nid=0x7227 waiting for monitor entry [0xafcca000..0xafccae30]
    at
org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure
(FailoverTransport.java:236)
    - waiting to lock <0x88f4e290> (a java.lang.Object)
    at
org.apache.activemq.transport.failover.FailoverTransport$2.onException(
FailoverTransport.java:209)
    at org.apache.activemq.transport.TransportFilter.onException(
TransportFilter.java:98)
    at org.apache.activemq.transport.WireFormatNegotiator.onException(
WireFormatNegotiator.java:143)
    at org.apache.activemq.transport.InactivityMonitor.onException(
InactivityMonitor.java:155)
    at org.apache.activemq.transport.TransportSupport.onException(
TransportSupport.java:95)
    at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java
:180)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Task" daemon prio=1 tid=0x08805cc0 nid=0x7226 runnable
[0xafd4b000..0xafd4bdb0]
    at java.net.SocketOutputStream.socketWrite0(Native Method)
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
    at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
    at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(
TcpBufferedOutputStream.java:105)
    at java.io.DataOutputStream.flush(DataOutputStream.java:106)
    at org.apache.activemq.transport.tcp.TcpTransport.oneway(
TcpTransport.java:159)
    at org.apache.activemq.transport.InactivityMonitor.oneway(
InactivityMonitor.java:144)
    - locked <0x8935abc0> (a
org.apache.activemq.transport.InactivityMonitor$2)
    at org.apache.activemq.transport.TransportFilter.oneway(
TransportFilter.java:82)
    at org.apache.activemq.transport.WireFormatNegotiator.oneway(
WireFormatNegotiator.java:91)
    at
org.apache.activemq.state.ConnectionStateTracker.restoreTempDestinations(
ConnectionStateTracker.java:173)
    at org.apache.activemq.state.ConnectionStateTracker.restore(
ConnectionStateTracker.java:95)
    at
org.apache.activemq.transport.failover.FailoverTransport.restoreTransport(
FailoverTransport.java:525)
    at org.apache.activemq.transport.failover.FailoverTransport$1.iterate(
FailoverTransport.java:120)
    - locked <0x88f4e290> (a java.lang.Object)
    at org.apache.activemq.thread.PooledTaskRunner.runTask(
PooledTaskRunner.java:118)
    at org.apache.activemq.thread.PooledTaskRunner$1.run(
PooledTaskRunner.java:42)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(
ThreadPoolExecutor.java:650)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(
ThreadPoolExecutor.java:675)
    at java.lang.Thread.run(Thread.java:595)

"Timer-0" daemon prio=1 tid=0x087fd108 nid=0x7225 in Object.wait()
[0xafdcc000..0xafdcd130]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88f23fc0> (a java.util.TaskQueue)
    at java.util.TimerThread.mainLoop(Timer.java:509)
    - locked <0x88f23fc0> (a java.util.TaskQueue)
    at java.util.TimerThread.run(Timer.java:462)

"Low Memory Detector" daemon prio=1 tid=0x080abd38 nid=0x7221 runnable
[0x00000000..0x00000000]

"CompilerThread0" daemon prio=1 tid=0x080aa788 nid=0x7220 waiting on
condition [0x00000000..0xb22d1998]

"Signal Dispatcher" daemon prio=1 tid=0x080a9770 nid=0x721f runnable
[0x00000000..0x00000000]

"Finalizer" daemon prio=1 tid=0x080a2058 nid=0x721e in Object.wait()
[0xb240d000..0xb240deb0]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88e8ed58> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
    - locked <0x88e8ed58> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
    at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)

"Reference Handler" daemon prio=1 tid=0x080a1318 nid=0x721d in Object.wait()
[0xb248e000..0xb248ee30]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88e8edd8> (a java.lang.ref.Reference$Lock)
    at java.lang.Object.wait(Object.java:474)
    at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
    - locked <0x88e8edd8> (a java.lang.ref.Reference$Lock)

"main" prio=1 tid=0x080618d0 nid=0x7217 waiting on condition
[0xbf80e000..0xbf80ed68]
    at sun.misc.Unsafe.park(Native Method)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(
AbstractQueuedSynchronizer.java:1841)
    at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java
:341)
    at org.apache.activemq.transport.FutureResponse.getResult(
FutureResponse.java:40)
    at org.apache.activemq.transport.ResponseCorrelator.request(
ResponseCorrelator.java:76)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(
ActiveMQConnection.java:1168)
    at org.apache.activemq.ActiveMQConnection.createTempDestination(
ActiveMQConnection.java:1713)
    at org.apache.activemq.ActiveMQSession.createTemporaryTopic(
ActiveMQSession.java:1227)
    at org.jencks.amqpool.PooledSession.createTemporaryTopic(
PooledSession.java:169)
    at uol.auction.messaging.TopicMessageBroker.request(
TopicMessageBroker.java:149)
    at uol.auction.messaging.TopicMessageBroker.request(
TopicMessageBroker.java:131)
    at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
DiagnosticMessageBrokerTest.java:46)
    at uol.auction.domain.business.DiagnosticMessageBrokerTest.main(
DiagnosticMessageBrokerTest.java:24)

"VM Thread" prio=1 tid=0x0809fee0 nid=0x7218 runnable

"VM Periodic Task Thread" prio=1 tid=0x080cea00 nid=0x7222 waiting on
condition


2007/9/27, Márcio Moraes <mmoraes.br@gmail.com>:
>
> I ran somes testes using kaha as persistence
>
> My test send many messages to a consumer, after ~6000 messages client
> hangs.
>
> Following is the client stack trace
>
> "ActiveMQ Session Task" daemon prio=1 tid=0x08878a68 nid=0x70af waiting on
> condition [0xafa73000..0xafa73db0]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> (AbstractQueuedSynchronizer.java :716)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> (AbstractQueuedSynchronizer.java:771)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> (AbstractQueuedSynchronizer.java :1099)
>     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> SynchronousQueue.java:265)
>     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> :400)
>     at java.util.concurrent.ThreadPoolExecutor.getTask (
> ThreadPoolExecutor.java:470)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:674)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Scheduler" daemon prio=1 tid=0x088523e8 nid=0x70ae in
> Object.wait() [0xafaf4000..0xafaf5130]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f57148> (a java.util.TaskQueue)
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f57148> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
> tid=0x0882df60 nid=0x70ad runnable [0xafb75000..0xafb760b0]
>     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 :50)
>     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
> TcpBufferedInputStream.java:58)
>     at java.io.DataInputStream.readInt(DataInputStream.java:353)
>     at org.apache.activemq.openwire.OpenWireFormat.unmarshal (
> OpenWireFormat.java:268)
>     at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
> TcpTransport.java:196)
>     at org.apache.activemq.transport.tcp.TcpTransport.doRun(
> TcpTransport.java:188)
>     at org.apache.activemq.transport.tcp.TcpTransport.run (
> TcpTransport.java:176)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Task" daemon prio=1 tid=0x0882e500 nid=0x70ac waiting on
> condition [0xafbf6000..0xafbf7030]
>     at sun.misc.Unsafe.park (Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> (AbstractQueuedSynchronizer.java:716)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> (AbstractQueuedSynchronizer.java:771)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> (AbstractQueuedSynchronizer.java :1099)
>     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> SynchronousQueue.java:265)
>     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> :400)
>     at java.util.concurrent.ThreadPoolExecutor.getTask (
> ThreadPoolExecutor.java:470)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:674)
>     at java.lang.Thread.run(Thread.java:595)
>
> "Timer-0" daemon prio=1 tid=0x08812620 nid=0x70ab in Object.wait()
> [0xafc77000..0xafc77fb0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f31158> (a java.util.TaskQueue)
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f31158> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "ReaderThread" prio=1 tid=0x0829b5f0 nid=0x70a8 runnable
> [0xafcf8000..0xafcf8f30]
>     at java.net.SocketInputStream.socketRead0(Native Method)
>     at java.net.SocketInputStream.read(SocketInputStream.java:129)
>     at sun.nio.cs.StreamDecoder$CharsetSD.readBytes(StreamDecoder.java
> :411)
>     at sun.nio.cs.StreamDecoder$CharsetSD.implRead(StreamDecoder.java:453)
>     at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:183)
>     - locked <0x88ebeca0> (a java.io.InputStreamReader)
>     at java.io.InputStreamReader.read(InputStreamReader.java:167)
>     at java.io.BufferedReader.fill (BufferedReader.java:136)
>     at java.io.BufferedReader.readLine(BufferedReader.java:299)
>     - locked <0x88ebeca0> (a java.io.InputStreamReader)
>     at java.io.BufferedReader.readLine(BufferedReader.java:362)
>     at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner$ReaderThread.run(
> RemoteTestRunner.java:140)
>
> "Low Memory Detector" daemon prio=1 tid=0x080ac0e0 nid=0x70a6 runnable
> [0x00000000..0x00000000]
>
> "CompilerThread0" daemon prio=1 tid=0x080aab30 nid=0x70a5 waiting on
> condition [0x00000000..0xb2265798]
>
> "Signal Dispatcher" daemon prio=1 tid=0x080a9ba8 nid=0x70a4 runnable
> [0x00000000..0x00000000]
>
> "Finalizer" daemon prio=1 tid=0x080a23f8 nid=0x70a3 in Object.wait()
> [0xb23a1000..0xb23a20b0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock )
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
>     - locked <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
>     at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)
>
> "Reference Handler" daemon prio=1 tid=0x080a16b8 nid=0x70a2 in Object.wait()
> [0xb2422000..0xb2423030]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e954b8> (a java.lang.ref.Reference$Lock)
>     at java.lang.Object.wait(Object.java:474)
>     at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
>     - locked <0x88e954b8> (a java.lang.ref.Reference$Lock)
>
> "main" prio=1 tid=0x08061c70 nid=0x709b waiting on condition
> [0xbfd0f000..0xbfd100f8]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park (LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await
> (AbstractQueuedSynchronizer.java:1841)
>     at java.util.concurrent.ArrayBlockingQueue.take(
> ArrayBlockingQueue.java :341)
>     at org.apache.activemq.transport.FutureResponse.getResult(
> FutureResponse.java:40)
>     at org.apache.activemq.transport.ResponseCorrelator.request(
> ResponseCorrelator.java:76)
>     at org.apache.activemq.ActiveMQConnection.syncSendPacket (
> ActiveMQConnection.java:1168)
>     at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1635)
>     - locked <0x88f67550> (a java.lang.Object)
>     at org.apache.activemq.ActiveMQMessageProducer.send (
> ActiveMQMessageProducer.java:226)
>     at org.apache.activemq.ActiveMQMessageProducerSupport.send(
> ActiveMQMessageProducerSupport.java:299)
>     at org.apache.activemq.ActiveMQTopicPublisher.publish(
> ActiveMQTopicPublisher.java :171)
>     at org.jencks.amqpool.PooledTopicPublisher.publish(
> PooledTopicPublisher.java:50)
>     at uol.auction.messaging.TopicMessageBroker.request(
> TopicMessageBroker.java:154)
>     at uol.auction.messaging.TopicMessageBroker.request (
> TopicMessageBroker.java:131)
>     at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
> DiagnosticMessageBrokerTest.java:42)
>     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke (
> NativeMethodAccessorImpl.java:39)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke(
> DelegatingMethodAccessorImpl.java:25)
>     at java.lang.reflect.Method.invoke(Method.java:585)
>     at junit.framework.TestCase.runTest (TestCase.java:154)
>     at junit.framework.TestCase.runBare(TestCase.java:127)
>     at junit.framework.TestResult$1.protect(TestResult.java:106)
>     at junit.framework.TestResult.runProtected(TestResult.java:124)
>     at junit.framework.TestResult.run(TestResult.java:109)
>     at junit.framework.TestCase.run(TestCase.java:118)
>     at junit.framework.TestSuite.runTest(TestSuite.java:208)
>     at junit.framework.TestSuite.run( TestSuite.java:203)
>     at
> org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(
> JUnit3TestReference.java:128)
>     at org.eclipse.jdt.internal.junit.runner.TestExecution.run(
> TestExecution.java:38)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> RemoteTestRunner.java:460)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> RemoteTestRunner.java:673)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run (
> RemoteTestRunner.java:386)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(
> RemoteTestRunner.java:196)
>
> "VM Thread" prio=1 tid=0x080a0280 nid=0x70a1 runnable
>
> "VM Periodic Task Thread" prio=1 tid=0x080ad5d0 nid=0x70a7 waiting on
> condition
>
> Att,
>
> Márcio Moraes
>
>
> 2007/9/27, Hiram Chirino <hiram@hiramchirino.com>:
> >
> > Howdy folks.
> >
> > I've done the first release candidate build of activemq 5.0.0.  You can
> > get the
> > binary distributions here:
> >
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/<http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/>
> > maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > <http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven2>
> > maven 1 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1<http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven1>
> >
> > Please check out this build and let me know if you see anything out of
> > place.
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message