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 <[EMAIL PROTECTED]>:
>
> 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/
> maven 2 repo:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo:
> http://people.apache.org/~chirino/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
>
