Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Date: Sat, 2 Jul 2011 19:32:22 +0000 (UTC)
From: "Timothy Bish (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Message-ID: 
 <1252432517.222.1309635142454.JavaMail.tomcat@hel.zones.apache.org>
Subject: [jira] [Closed] (AMQ-2026)
 PublishOnQueueConsumedMessageUsingActivemqXMLTest  sometimes hangs on
 tearDown
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable


     [ https://issues.apache.org/jira/browse/AMQ-2026?page=3Dcom.atlassian.=
jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish closed AMQ-2026.
-----------------------------

       Resolution: Not A Problem
    Fix Version/s:     (was: 5.6.0)

Test history doesn't show any current problems with the test

> PublishOnQueueConsumedMessageUsingActivemqXMLTest  sometimes hangs on tea=
rDown
> -------------------------------------------------------------------------=
-----
>
>                 Key: AMQ-2026
>                 URL: https://issues.apache.org/jira/browse/AMQ-2026
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Test Cases
>    Affects Versions: 5.2.0
>         Environment: Solaris 9 9/04 SPARC, Java 1.5.0_11-b03, Maven 2.0.9=
, ActiveMQ 5.2.0 (Revision: 724629)
>            Reporter: Eduardo Corral
>            Priority: Minor
>         Attachments: PublishOnQueueConsumedMessageUsingActivemqXMLTest.st=
ack.txt
>
>
> While executing the full install, with {{maven clean install}}, tests som=
etimes get stuck on {{PublishOnQueueConsumedMessageUsingActivemqXMLTest}}. =
A thread dump reveals that main thread is waiting for VM transport to stop =
on tearDown:
> {noformat}
> "ActiveMQ Transport Stopper: vm://localhost#0" prio=3D10 tid=3D0x00129790=
 nid=3D0x6f waiting on condition [0xf167e000..0xf167fc28]
>         at sun.misc.Unsafe.park(Native Method)
>         at java.util.concurrent.locks.LockSupport.park(LockSupport.java:1=
18)
>         at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndC=
heckInterrupt(AbstractQueuedSynchronizer.java:681)
>         at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquir=
eSharedInterruptibly(AbstractQueuedSynchronizer.java:837)
>         at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireS=
haredInterruptibly(AbstractQueuedSynchronizer.java:1144)
>         at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:=
199)
>         at org.apache.activemq.store.journal.JournalPersistenceAdapter.ch=
eckpoint(JournalPersistenceAdapter.java:319)
>         at org.apache.activemq.store.journal.JournalMessageStore.getMessa=
geCount(JournalMessageStore.java:403)
>         at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.g=
etStoreSize(QueueStorePrefetch.java:63)
>         - locked <0xb4cbad70> (a org.apache.activemq.broker.region.cursor=
s.QueueStorePrefetch)
>         at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.=
gc(AbstractStoreCursor.java:212)
>         - locked <0xb4cbad70> (a org.apache.activemq.broker.region.cursor=
s.QueueStorePrefetch)
>         at org.apache.activemq.broker.region.cursors.StoreQueueCursor.gc(=
StoreQueueCursor.java:257)
>         - locked <0xb4cbba18> (a org.apache.activemq.broker.region.cursor=
s.StoreQueueCursor)
>         at org.apache.activemq.broker.region.Queue.removeSubscription(Que=
ue.java:308)
>         at org.apache.activemq.broker.region.AbstractRegion.removeConsume=
r(AbstractRegion.java:324)
>         at org.apache.activemq.broker.region.RegionBroker.removeConsumer(=
RegionBroker.java:392)
>         at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerF=
ilter.java:114)
>         at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerF=
ilter.java:114)
>         at org.apache.activemq.advisory.AdvisoryBroker.removeConsumer(Adv=
isoryBroker.java:222)
>         at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerF=
ilter.java:114)
>         at org.apache.activemq.broker.MutableBrokerFilter.removeConsumer(=
MutableBrokerFilter.java:121)
>         at org.apache.activemq.broker.TransportConnection.processRemoveCo=
nsumer(TransportConnection.java:565)
>         at org.apache.activemq.broker.TransportConnection.processRemoveSe=
ssion(TransportConnection.java:600)
>         at org.apache.activemq.broker.TransportConnection.processRemoveCo=
nnection(TransportConnection.java:705)
>         - locked <0xb4c1e158> (a org.apache.activemq.broker.TransportConn=
ection)
>         at org.apache.activemq.broker.TransportConnection.doStop(Transpor=
tConnection.java:1000)
>         at org.apache.activemq.broker.TransportConnection$3.run(Transport=
Connection.java:925)
> "main" prio=3D10 tid=3D0x00036a00 nid=3D0x1 waiting for monitor entry [0x=
ffbfc000..0xffbfe8b8]
>         at org.apache.activemq.broker.region.cursors.StoreQueueCursor.sto=
p(StoreQueueCursor.java:79)
>         - waiting to lock <0xb4cbba18> (a org.apache.activemq.broker.regi=
on.cursors.StoreQueueCursor)
>         at org.apache.activemq.broker.region.Queue.stop(Queue.java:541)
>         at org.apache.activemq.broker.region.AbstractRegion.stop(Abstract=
Region.java:109)
>         - locked <0xb4baed50> (a java.lang.Object)
>         at org.apache.activemq.util.ServiceStopper.stop(ServiceStopper.ja=
va:41)
>         at org.apache.activemq.broker.region.RegionBroker.doStop(RegionBr=
oker.java:614)
>         at org.apache.activemq.broker.jmx.ManagedRegionBroker.doStop(Mana=
gedRegionBroker.java:109)
>         at org.apache.activemq.broker.region.RegionBroker.stop(RegionBrok=
er.java:185)
>         at org.apache.activemq.broker.TransactionBroker.stop(TransactionB=
roker.java:117)
>         at org.apache.activemq.broker.BrokerFilter.stop(BrokerFilter.java=
:158)
>         at org.apache.activemq.broker.BrokerFilter.stop(BrokerFilter.java=
:158)
>         at org.apache.activemq.broker.BrokerService$3.stop(BrokerService.=
java:1580)
>         at org.apache.activemq.util.ServiceStopper.stop(ServiceStopper.ja=
va:41)
>         at org.apache.activemq.broker.BrokerService.stop(BrokerService.ja=
va:521)
>         at org.apache.activemq.usecases.PublishOnQueueConsumedMessageUsin=
gActivemqXMLTest.tearDown(PublishOnQueueConsumedMessageUsingActivemqXMLTest=
.java:71)
>         at junit.framework.TestCase.runBare(TestCase.java:130)
>         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 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccess=
orImpl.java:39)
>         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMeth=
odAccessorImpl.java:25)
>         at java.lang.reflect.Method.invoke(Method.java:585)
>         at org.apache.maven.surefire.junit.JUnitTestSet.execute(JUnitTest=
Set.java:210)
>         at org.apache.maven.surefire.suite.AbstractDirectoryTestSuite.exe=
cuteTestSet(AbstractDirectoryTestSuite.java:135)
>         at org.apache.maven.surefire.suite.AbstractDirectoryTestSuite.exe=
cute(AbstractDirectoryTestSuite.java:160)
>         at org.apache.maven.surefire.Surefire.run(Surefire.java:81)
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccess=
orImpl.java:39)
>         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMeth=
odAccessorImpl.java:25)
>         at java.lang.reflect.Method.invoke(Method.java:585)
>         at org.apache.maven.surefire.booter.SurefireBooter.runSuitesInPro=
cess(SurefireBooter.java:182)
>         at org.apache.maven.surefire.booter.SurefireBooter.main(SurefireB=
ooter.java:743)
> {noformat}
> {{org.apache.activemq.store.journal.JournalPersistenceAdapter.checkpoint}=
}  is waiting on
> {noformat}
> if (sync) {
>    LOG.debug("Waking for checkpoint to complete.");
>    latch.await();
> }
> {noformat}
> But on the thread dump I see no {{ActiveMQ Journal Checkpoint Worker}} to=
 perform the actual {{org.apache.activemq.store.journal.JournalPersistenceA=
dapter.doCheckpoint}}. I haven't thoroughly inspected the code, but it seem=
s that the journal is already stopped when the message count is requested. =
=C2=BFIs this test-setup related or is some problem with the stop sequence?

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira