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 C4C2E7E1C for ; Wed, 26 Oct 2011 07:55:58 +0000 (UTC) Received: (qmail 28590 invoked by uid 500); 26 Oct 2011 07:55:58 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 28361 invoked by uid 500); 26 Oct 2011 07:55:55 -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 28353 invoked by uid 99); 26 Oct 2011 07:55:53 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 26 Oct 2011 07:55:53 +0000 X-ASF-Spam-Status: No, hits=-2000.5 required=5.0 tests=ALL_TRUSTED,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; Wed, 26 Oct 2011 07:55:51 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 8D65531CABE for ; Wed, 26 Oct 2011 07:53:32 +0000 (UTC) Date: Wed, 26 Oct 2011 07:53:32 +0000 (UTC) From: "Andrew Gurinovitch (Commented) (JIRA)" To: dev@activemq.apache.org Message-ID: <1326902622.17220.1319615612580.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=13135780#comment-13135780 ] Andrew Gurinovitch commented on AMQ-3098: ----------------------------------------- The same problem happened to me. The most pity part is that activemq did not help to diagnose broken database and proceed to work like if the messages are simply enqueued w/o consumer. > 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. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira