activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hiram Chirino" <hi...@hiramchirino.com>
Subject Re: Please help check ActiveMQ 5.0.0 RC1
Date Fri, 28 Sep 2007 13:58:48 GMT
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 <mmoraes.br@gmail.com> 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 <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/
> > 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

Mime
View raw message