From dev-return-26538-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org Mon May 2 18:24:42 2011 Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D74FC3677 for ; Mon, 2 May 2011 18:24:42 +0000 (UTC) Received: (qmail 45893 invoked by uid 500); 2 May 2011 18:24:42 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 45860 invoked by uid 500); 2 May 2011 18:24:42 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 45852 invoked by uid 99); 2 May 2011 18:24:42 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 May 2011 18:24:42 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 May 2011 18:24:41 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 59488BE21D for ; Mon, 2 May 2011 18:24:03 +0000 (UTC) Date: Mon, 2 May 2011 18:24:03 +0000 (UTC) From: "Josh Carlson (JIRA)" To: dev@activemq.apache.org Message-ID: <745619626.15790.1304360643354.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <22569607.208011292814480641.JavaMail.jira@thor> Subject: [jira] [Commented] (AMQ-3098) Failed to page in more queue messages - Cannot consume messages MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/AMQ-3098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13027754#comment-13027754 ] Josh Carlson commented on AMQ-3098: ----------------------------------- In our case we can't restart AMQ, it just keeps failing with the same exception on start up. We have to rm -f * the kahDB message store in order to start it back up again. Does this exception mean that the journal is corrupted? Do you think that setting checkForCurrptJournalFiles may help, it says that it will attempt to recover them if they are corrupt. > Failed to page in more queue messages - Cannot consume messages > --------------------------------------------------------------- > > Key: AMQ-3098 > URL: https://issues.apache.org/jira/browse/AMQ-3098 > Project: ActiveMQ > Issue Type: Bug > Affects Versions: 5.4.2 > Reporter: Loc Truong > Priority: Critical > > With the error messages below, Consumers cannot consume any message until clearing the data folder then restart ActiveMQ, assuming old messages are lost. > ERROR | Failed to fill batch > java.lang.RuntimeException: java.io.IOException: Invalid location: 1711:34233, : java.lang.NegativeArraySizeException > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:265) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:110) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1678) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1898) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1425) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36) > Caused by: java.io.IOException: Invalid location: 1711:34233, : java.lang.NegativeArraySizeException > at org.apache.kahadb.journal.DataFileAccessor.readRecord(DataFileAccessor.java:94) > at org.apache.kahadb.journal.Journal.read(Journal.java:596) > at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:786) > at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:956) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:494) > at org.apache.kahadb.page.Transaction.execute(Transaction.java:728) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:485) > at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:88) > at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:97) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:262) > ... 7 more > ERROR | Failed to page in more queue messages > java.lang.RuntimeException: java.lang.RuntimeException: java.io.IOException: Invalid location: 1711:34233, : java.lang.NegativeArraySizeException > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:113) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1678) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1898) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1425) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36) > Caused by: java.lang.RuntimeException: java.io.IOException: Invalid location: 1711:34233, : java.lang.NegativeArraySizeException > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:265) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:110) > ... 6 more > Caused by: java.io.IOException: Invalid location: 1711:34233, : java.lang.NegativeArraySizeException > at org.apache.kahadb.journal.DataFileAccessor.readRecord(DataFileAccessor.java:94) > at org.apache.kahadb.journal.Journal.read(Journal.java:596) > at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:786) > at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:956) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:494) > at org.apache.kahadb.page.Transaction.execute(Transaction.java:728) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:485) > at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:88) > at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:97) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:262) > ... 7 more -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira