Hi Márcio, What usage scenario was that? Queues, Persistent messages, over tcp:// using a the default broker? Were you using transactions?
On 9/27/07, Márcio Moraes <[EMAIL PROTECTED]> wrote: > 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 > > > -- Regards, Hiram Blog: http://hiramchirino.com
