Return-Path: 
 <dev-return-34624-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
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 56690D4EF
	for <apmail-activemq-dev-archive@www.apache.org>;
 Mon, 12 Nov 2012 08:40:14 +0000 (UTC)
Received: (qmail 63163 invoked by uid 500); 12 Nov 2012 08:40:14 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 63105 invoked by uid 500); 12 Nov 2012 08:40:13 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 63068 invoked by uid 99); 12 Nov 2012 08:40:12 -0000
Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Nov 2012 08:40:12 +0000
Date: Mon, 12 Nov 2012 08:40:11 +0000 (UTC)
From: "Bill Wan (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Message-ID: <1879904693.99638.1352709612141.JavaMail.jiratomcat@arcas>
In-Reply-To: <975371858.99627.1352709374141.JavaMail.jiratomcat@arcas>
Subject: [jira] [Updated] (AMQ-4170) Crash when clean inactive destination:
 java.io.EOFException: Chunk stream does not exist at page
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-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Bill Wan updated AMQ-4170:
--------------------------

    Attachment: activemq.log

add exception log
                
> Crash when clean inactive destination: java.io.EOFException: Chunk stream does not exist at page 
> -------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-4170
>                 URL: https://issues.apache.org/jira/browse/AMQ-4170
>             Project: ActiveMQ
>          Issue Type: Bug
>    Affects Versions: 5.5.1
>            Reporter: Bill Wan
>         Attachments: activemq.log
>
>
> I add below configuration to clean inactive destination and expired message for every 2 hours
> <destinationPolicy>
>             <policyMap>
>               <policyEntries>
>                 <policyEntry topic=">" producerFlowControl="true" memoryLimit="1mb" gcInactiveDestinations="true" inactiveTimoutBeforeGC="7200000" expireMessagesPeriod="7200000">
>                   <pendingSubscriberPolicy>
>                     <vmCursor />
>                   </pendingSubscriberPolicy>
>                 </policyEntry>
>                 <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb" gcInactiveDestinations="true" inactiveTimoutBeforeGC="7200000" expireMessagesPeriod="7200000">
>                   <pendingQueuePolicy>
>                     <vmQueueCursor/>
>                   </pendingQueuePolicy>
>                 </policyEntry>
>               </policyEntries>
>             </policyMap>
>         </destinationPolicy>
> After MQ run for several days, it will crash when scheduler do such clean job, the crash exception is:
> 2012-11-12 01:03:58,917 | INFO  | 5099ae91f17021cb20b0b157 Inactive for longer than 7200000 ms - removing ... | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[broker-cluster-194] Scheduler
> 2012-11-12 01:04:01,907 | INFO  | Transport failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///183.177.33.93:39617
> 2012-11-12 01:04:02,288 | ERROR | KahaDB failed to store to Journal | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Broker[broker-cluster-194] Scheduler
> java.io.EOFException: Chunk stream does not exist at page: 1868
> 	at org.apache.kahadb.page.Transaction$2.readPage(Transaction.java:454)
> 	at org.apache.kahadb.page.Transaction$2.<init>(Transaction.java:431)
> 	at org.apache.kahadb.page.Transaction.openInputStream(Transaction.java:428)
> 	at org.apache.kahadb.page.Transaction.load(Transaction.java:404)
> 	at org.apache.kahadb.page.Transaction.load(Transaction.java:361)
> 	at org.apache.kahadb.index.BTreeIndex.loadNode(BTreeIndex.java:262)
> 	at org.apache.kahadb.index.BTreeIndex.getRoot(BTreeIndex.java:174)
> 	at org.apache.kahadb.index.BTreeIndex.clear(BTreeIndex.java:202)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.remove(MessageDatabase.java:2177)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.updateIndex(MessageDatabase.java:1105)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$16.execute(MessageDatabase.java:936)
> 	at org.apache.kahadb.page.Transaction.execute(Transaction.java:728)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:934)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$13.visit(MessageDatabase.java:884)
> 	at org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand.visit(KahaRemoveDestinationCommand.java:130)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:856)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:783)
> 	at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.removeAllMessages(KahaDBStore.java:384)
> 	at org.apache.activemq.store.ProxyMessageStore.removeAllMessages(ProxyMessageStore.java:56)
> 	at org.apache.activemq.broker.region.BaseDestination.dispose(BaseDestination.java:503)
> 	at org.apache.activemq.broker.region.AbstractRegion.dispose(AbstractRegion.java:511)
> 	at org.apache.activemq.broker.region.AbstractRegion.removeDestination(AbstractRegion.java:198)
> 	at org.apache.activemq.broker.jmx.ManagedQueueRegion.removeDestination(ManagedQueueRegion.java:62)
> 	at org.apache.activemq.broker.region.RegionBroker.removeDestination(RegionBroker.java:324)
> 	at org.apache.activemq.broker.BrokerFilter.removeDestination(BrokerFilter.java:149)
> 	at org.apache.activemq.advisory.AdvisoryBroker.removeDestination(AdvisoryBroker.java:173)
> 	at org.apache.activemq.broker.BrokerFilter.removeDestination(BrokerFilter.java:149)
> 	at org.apache.activemq.broker.BrokerFilter.removeDestination(BrokerFilter.java:149)
> 	at org.apache.activemq.broker.BrokerFilter.removeDestination(BrokerFilter.java:149)
> 	at org.apache.activemq.broker.MutableBrokerFilter.removeDestination(MutableBrokerFilter.java:155)
> 	at org.apache.activemq.broker.region.RegionBroker.purgeInactiveDestinations(RegionBroker.java:959)
> 	at org.apache.activemq.broker.region.RegionBroker$1.run(RegionBroker.java:110)
> 	at org.apache.activemq.thread.SchedulerTimerTask.run(SchedulerTimerTask.java:33)
> 	at java.util.TimerThread.mainLoop(Timer.java:555)
> 	at java.util.TimerThread.run(Timer.java:505)

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira