Sorry. Connection tcp:// Consumer: Durable Topic Persistent Message (tested with kaha and journal derby) I am not using transaction (topicConnection.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE)
I am test it with other scenario. I let you know. Thanks 2007/9/28, Hiram Chirino <[EMAIL PROTECTED]>: > > 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 >
