Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Message-ID: <861219096.1242958071330.JavaMail.jira@brutus>
Date: Thu, 21 May 2009 19:07:51 -0700 (PDT)
From: "madderla prem kumar (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Updated: (AMQ-2264) Queue of a Virtual topic Messages not
 getting dequeued
In-Reply-To: <1673449022.1242958071265.JavaMail.jira@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit


     [ https://issues.apache.org/activemq/browse/AMQ-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

madderla prem kumar updated AMQ-2264:
-------------------------------------

    Priority: Blocker  (was: Major)

> Queue of a Virtual topic Messages not getting dequeued
> ------------------------------------------------------
>
>                 Key: AMQ-2264
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2264
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.2.0
>            Reporter: madderla prem kumar
>            Priority: Blocker
>
> Have multiple consumers to queue (queue of a virtual topic) , Am using the spring DefaultMessageListnerContainer . Am running with a network of 2 brokers , networked using static url in network connector.
> Web console shows the some consumers , even when the consumers are shut down , But Jconsole correctly shows 0 subscriptions.
> I greatly appreciate your response . 
> Caused by: java.lang.IllegalStateException: Trying to access an inactive page: 18432
>         at org.apache.activemq.kaha.impl.index.hash.HashIndex.lookupPage(HashIndex.java:347)
>         at org.apache.activemq.kaha.impl.index.hash.HashPageInfo.begin(HashPageInfo.java:96)
>         at org.apache.activemq.kaha.impl.index.hash.HashBin.getRetrievePage(HashBin.java:269)
>         at org.apache.activemq.kaha.impl.index.hash.HashBin.getHashEntry(HashBin.java:244)
>         at org.apache.activemq.kaha.impl.index.hash.HashBin.find(HashBin.java:111)
>         at org.apache.activemq.kaha.impl.index.hash.HashIndex.get(HashIndex.java:294)
>         at org.apache.activemq.kaha.impl.container.MapContainerImpl.get(MapContainerImpl.java:203)
>         at org.apache.activemq.store.kahadaptor.KahaReferenceStore.getMessageReference(KahaReferenceStore.java:151)
>         at org.apache.activemq.store.amq.AMQMessageStore.getLocation(AMQMessageStore.java:460)
>         at org.apache.activemq.store.amq.AMQMessageStore.getMessage(AMQMessageStore.java:433)
>         at org.apache.activemq.store.amq.RecoveryListenerAdapter.recoverMessageReference(RecoveryListenerAdapter.java:54)
>         at org.apache.activemq.store.kahadaptor.KahaReferenceStore.recoverReference(KahaReferenceStore.java:82)
>         at org.apache.activemq.store.kahadaptor.KahaReferenceStore.recoverNextMessages(KahaReferenceStore.java:120)
>         at org.apache.activemq.store.amq.AMQMessageStore.recoverNextMessages(AMQMessageStore.java:533)
>         at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:75)
>         at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:227)
>         ... 10 more
> ERROR Queue                          - Failed to page in more queue messages
> java.lang.RuntimeException: java.lang.RuntimeException: java.lang.IllegalStateException: Trying to access an inactive page: 18432
>         at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:103)
>         at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157)
>         at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1179)
>         at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1308)
>         at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1011)
>         at org.apache.activemq.thread.DeterministicTaskRunner.runTask(DeterministicTaskRunner.java:84)
>         at org.apache.activemq.thread.DeterministicTaskRunner$1.run(DeterministicTaskRunner.java:41)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>         at java.lang.Thread.run(Thread.java:595)

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.