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 Fri, 28 Sep 2007 22:44:29 GMT
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 <hiram@hiramchirino.com>:
>
> 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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message