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 63CBA8391 for ; Wed, 24 Aug 2011 12:21:57 +0000 (UTC) Received: (qmail 23906 invoked by uid 500); 24 Aug 2011 12:21:57 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 23174 invoked by uid 500); 24 Aug 2011 12:21:54 -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 23166 invoked by uid 99); 24 Aug 2011 12:21:52 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Aug 2011 12:21:52 +0000 X-ASF-Spam-Status: No, hits=-2000.5 required=5.0 tests=ALL_TRUSTED,NORMAL_HTTP_TO_IP,RP_MATCHES_RCVD,WEIRD_PORT 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, 24 Aug 2011 12:21:49 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id A7671CD0C8 for ; Wed, 24 Aug 2011 12:21:29 +0000 (UTC) Date: Wed, 24 Aug 2011 12:21:29 +0000 (UTC) From: "Frank Gynnild (JIRA)" To: dev@activemq.apache.org Message-ID: <1201204612.9019.1314188489682.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <743229670.8777.1314177415329.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Commented] (AMQ-3470) Unable to pick up messages anymore, messages are lost - Looking for key xyz but not found in fileMap 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-3470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13090163#comment-13090163 ] Frank Gynnild commented on AMQ-3470: ------------------------------------ Unable to restart ActiveMQ after this occurs: --- 2011-08-24 14:19:48,446 | INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@6c4fc156: startup date [Wed Aug 24 14:19:48 CEST 2011]; root of context hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2011-08-24 14:19:52,644 | WARN | destroyApplicationContextOnStop parameter is deprecated, please use shutdown hooks instead | org.apache.activemq.xbean.XBeanBrokerService | main 2011-08-24 14:19:52,655 | INFO | PListStore:[C:\ActiveMQ\data\IES_CARMINE\tmp_storage ] started | org.apache.activemq.store.kahadb.plist.PListStore | main 2011-08-24 14:19:52,739 | INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\ActiveMQ\data\kahadb] | org.apache.activemq.broker.BrokerService | main 2011-08-24 14:19:53,162 | INFO | KahaDB is version 3 | org.apache.activemq.store.kahadb.MessageDatabase | main 2011-08-24 14:19:53,281 | INFO | Recovering from the journal ... | org.apache.activemq.store.kahadb.MessageDatabase | main 2011-08-24 14:19:53,282 | INFO | Recovery replayed 1 operations from the journal in 0.092 seconds. | org.apache.activemq.store.kahadb.MessageDatabase | main 2011-08-24 14:19:53,463 | INFO | Some journal files are missing: [652] | org.apache.activemq.store.kahadb.MessageDatabase | main 2011-08-24 14:19:53,469 | ERROR | Failed to start ActiveMQ JMS Message Broker. Reason: java.io.IOException: Detected missing/corrupt journal files. 1 messages affected. | org.apache.activemq.broker.BrokerService | main java.io.IOException: Detected missing/corrupt journal files. 1 messages affected. at org.apache.activemq.store.kahadb.MessageDatabase.recoverIndex(MessageDatabase.java:650) at org.apache.activemq.store.kahadb.MessageDatabase$6.execute(MessageDatabase.java:473) at org.apache.kahadb.page.Transaction.execute(Transaction.java:760) at org.apache.activemq.store.kahadb.MessageDatabase.recover(MessageDatabase.java:471) at org.apache.activemq.store.kahadb.MessageDatabase.recover(MessageDatabase.java:441) at org.apache.activemq.store.kahadb.MessageDatabase.open(MessageDatabase.java:303) at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:361) at org.apache.activemq.store.kahadb.MessageDatabase.doStart(MessageDatabase.java:199) at org.apache.activemq.store.kahadb.KahaDBStore.doStart(KahaDBStore.java:167) at org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:54) at org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter.start(KahaDBPersistenceAdapter.java:167) at org.apache.activemq.broker.BrokerService.start(BrokerService.java:494) at org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:60) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) at java.lang.reflect.Method.invoke(Unknown Source) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1536) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1477) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1409) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456) at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:291) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:288) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:190) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:574) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:895) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:425) at org.apache.xbean.spring.context.ResourceXmlApplicationContext.(ResourceXmlApplicationContext.java:64) at org.apache.xbean.spring.context.ResourceXmlApplicationContext.(ResourceXmlApplicationContext.java:52) at org.apache.activemq.xbean.XBeanBrokerFactory$1.(XBeanBrokerFactory.java:106) at org.apache.activemq.xbean.XBeanBrokerFactory.createApplicationContext(XBeanBrokerFactory.java:106) at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBrokerFactory.java:71) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:71) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:54) at org.apache.activemq.console.command.StartCommand.startBroker(StartCommand.java:115) at org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:74) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57) at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:148) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57) at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:90) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) at java.lang.reflect.Method.invoke(Unknown Source) at org.apache.activemq.console.Main.runTaskClass(Main.java:251) at org.apache.activemq.console.Main.main(Main.java:107) 2011-08-24 14:19:53,482 | INFO | ActiveMQ Message Broker (IES_CARMINE, null) is shutting down | org.apache.activemq.broker.BrokerService | main 2011-08-24 14:19:53,483 | INFO | Connector openwire Stopped | org.apache.activemq.broker.TransportConnector | main 2011-08-24 14:19:53,494 | INFO | PListStore:[C:\ActiveMQ\data\IES_CARMINE\tmp_storage ] stopped | org.apache.activemq.store.kahadb.plist.PListStore | main 2011-08-24 14:19:53,495 | INFO | Stopping async queue tasks | org.apache.activemq.store.kahadb.KahaDBStore | main 2011-08-24 14:19:53,495 | INFO | Stopping async topic tasks | org.apache.activemq.store.kahadb.KahaDBStore | main 2011-08-24 14:19:53,495 | INFO | Stopped KahaDB | org.apache.activemq.store.kahadb.KahaDBStore | main 2011-08-24 14:19:53,705 | INFO | ActiveMQ JMS Message Broker (IES_CARMINE, null) stopped | org.apache.activemq.broker.BrokerService | main --- > Unable to pick up messages anymore, messages are lost - Looking for key xyz but not found in fileMap > ---------------------------------------------------------------------------------------------------- > > Key: AMQ-3470 > URL: https://issues.apache.org/jira/browse/AMQ-3470 > Project: ActiveMQ > Issue Type: Bug > Affects Versions: 5.5.0 > Environment: Used from .NET 4.0 > Apache.NMS.ActiveMQ.dll - 1.5.1.2341 > Apache.NMS.dll - 1.5.0.2194 > ActiveMQ - 5.5.0 > Reporter: Frank Gynnild > Priority: Blocker > > We've a C# test client that constantly produces and consumes messages of various sizes. > After successfully sending and receiving about 5.5 million messages, ActiveMQ enters > a certain state where: > - No more messages in the queue cannot be dequeued/received. > - Looking at the ActiveMQ browser, we're no longer able to see the message. > - The logs get filled up and rotate at a crazy pace. > - We aren't able to recover after this, restarting the ActiveMQ doesn't help. > We haven't been able to consistently reproduce this behavior, it can happen after > any numbers of messages (usually after some million messages). Last it took about 8 > hours before we could come into this stage. > The tests are very basic. > I've been able to catch the log when this happens: > --- > 2011-08-22 11:13:50,919 | INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@3479e304: startup date [Mon Aug 22 11:13:50 CEST 2011]; root of context hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main > 2011-08-22 11:13:54,638 | WARN | destroyApplicationContextOnStop parameter is deprecated, please use shutdown hooks instead | org.apache.activemq.xbean.XBeanBrokerService | main > 2011-08-22 11:13:54,645 | INFO | PListStore:C:\ActiveMQ\data\IES_CARMINE\tmp_storage started | org.apache.activemq.store.kahadb.plist.PListStore | main > 2011-08-22 11:13:54,723 | INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\ActiveMQ\data\kahadb] | org.apache.activemq.broker.BrokerService | main > 2011-08-22 11:13:54,932 | INFO | ActiveMQ 5.5.0 JMS Message Broker (IES_CARMINE) is starting | org.apache.activemq.broker.BrokerService | main > 2011-08-22 11:13:54,933 | INFO | For help or more information please see: http://activemq.apache.org/ | org.apache.activemq.broker.BrokerService | main > 2011-08-22 11:13:55,224 | INFO | Listening for connections at: tcp://Carmine:61616?keepAlive=true&wireFormat.tightEncodingEnabled=false&wireFormat.cacheEnabled=false | org.apache.activemq.transport.TransportServerThreadSupport | main > 2011-08-22 11:13:55,226 | INFO | Connector openwire Started | org.apache.activemq.broker.TransportConnector | main > 2011-08-22 11:13:55,233 | INFO | ActiveMQ JMS Message Broker (IES_CARMINE, ID:Carmine-60118-1314004434990-0:1) started | org.apache.activemq.broker.BrokerService | main > 2011-08-22 11:13:55,390 | INFO | jetty-7.1.6.v20100715 | org.eclipse.jetty.util.log | main > 2011-08-22 11:13:56,043 | INFO | ActiveMQ WebConsole initialized. | org.apache.activemq.web.WebConsoleStarter | main > 2011-08-22 11:13:56,367 | INFO | Initializing Spring FrameworkServlet 'dispatcher' | /admin | main > 2011-08-22 11:13:56,807 | INFO | ActiveMQ Console at http://0.0.0.0:8161/admin | org.eclipse.jetty.util.log | main > 2011-08-22 11:13:56,852 | INFO | WebApp@280236390 at http://0.0.0.0:8161/console | org.eclipse.jetty.util.log | main > 2011-08-22 11:13:56,876 | INFO | Started SelectChannelConnector@0.0.0.0:8161 | org.eclipse.jetty.util.log | main > 2011-08-23 19:45:41,881 | ERROR | Looking for key 11856 but not found in fileMap: {11857=db-11857.log number = 11857 , length = 1949} | org.apache.kahadb.journal.Journal | Queue:TestQueue > 2011-08-23 19:45:41,935 | ERROR | QueueStorePrefetch314000409 - Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | Queue:TestQueue > java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.kahadb.journal.Journal.getDataFile(Journal.java:350) > at org.apache.kahadb.journal.Journal.read(Journal.java:597) > at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:817) > at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:955) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:493) > 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:260) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:108) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1712) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > 2011-08-23 19:45:41,939 | ERROR | QueueStorePrefetch314000409 - Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | Queue:TestQueue > java.lang.RuntimeException: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:263) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:108) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1712) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > Caused by: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.kahadb.journal.Journal.getDataFile(Journal.java:350) > at org.apache.kahadb.journal.Journal.read(Journal.java:597) > at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:817) > at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:955) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:493) > 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:260) > ... 7 more > 2011-08-23 19:45:41,940 | ERROR | Failed to page in more queue messages | org.apache.activemq.broker.region.Queue | Queue:TestQueue > java.lang.RuntimeException: java.lang.RuntimeException: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:111) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1712) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > Caused by: java.lang.RuntimeException: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:263) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:108) > ... 6 more > Caused by: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.kahadb.journal.Journal.getDataFile(Journal.java:350) > at org.apache.kahadb.journal.Journal.read(Journal.java:597) > at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:817) > at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:955) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:493) > 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:260) > ... 7 more > 2011-08-23 19:45:41,942 | ERROR | Looking for key 11856 but not found in fileMap: {11857=db-11857.log number = 11857 , length = 19540} | org.apache.kahadb.journal.Journal | Queue:TestQueue > 2011-08-23 19:45:41,943 | ERROR | QueueStorePrefetch314000409 - Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | Queue:TestQueue > java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.kahadb.journal.Journal.getDataFile(Journal.java:350) > at org.apache.kahadb.journal.Journal.read(Journal.java:597) > at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:817) > at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:955) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:493) > 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:260) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:108) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1712) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > 2011-08-23 19:45:41,944 | ERROR | QueueStorePrefetch314000409 - Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | Queue:TestQueue > java.lang.RuntimeException: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:263) > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:108) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1712) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > Caused by: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.kahadb.journal.Journal.getDataFile(Journal.java:350) > at org.apache.kahadb.journal.Journal.read(Journal.java:597) > at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:817) > at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:955) > at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:493) > 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:260) > ... 7 more > 2011-08-23 19:45:41,945 | ERROR | Failed to page in more queue messages | org.apache.activemq.broker.region.Queue | Queue:TestQueue > java.lang.RuntimeException: java.lang.RuntimeException: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:111) > at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157) > at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1712) > at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) > at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) > at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > Caused by: java.lang.RuntimeException: java.io.IOException: Could not locate data file C:\ActiveMQ\data\kahadb\db-11856.log > at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:263) > at org.apa > --- > The logs repeat in an endless matter. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira