Kaha DB cannot locate queue data files
--------------------------------------

                 Key: AMQ-876
                 URL: https://issues.apache.org/activemq/browse/AMQ-876
             Project: ActiveMQ
          Issue Type: Bug
          Components: Message Store
    Affects Versions: 4.1
         Environment: WinXP
            Reporter: Vadim Pesochinskiy
             Fix For: 4.1


Keep getting exception below.  Note that you are looking for queue-data-1, but 
actual file name is data-queue-data-1

$ pwd
  /cygdrive/d/amq/activemq-kaha/kaha.db
$ ls
data-kaha-1  data-queue-data-1  index-kaha  index-queue-data  index-transactions

javax.jms.JMSException: java.io.IOException: Could not locate data file 
queue-data-1
        at 
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:46)
        at 
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1154)
        at 
org.apache.activemq.TransactionContext.commit(TransactionContext.java:260)
        at org.apache.activemq.ActiveMQSession.commit(ActiveMQSession.java:464)
        at 
com.barra.cp.common.io.MultiQueueReceiver.onMessage(MultiQueueReceiver.java:163)
        at 
com.barra.cp.common.io.SingleMessageMultiQueueReceiver$OneMessageAtATime.runMultiQueue(SingleMessageMultiQueueReceiver.java:176)
        at 
com.barra.cp.common.io.SingleMessageMultiQueueReceiver$OneMessageAtATime.doRun(SingleMessageMultiQueueReceiver.java:143)
        at 
com.barra.cp.common.io.SingleMessageMultiQueueReceiver$OneMessageAtATime.run(SingleMessageMultiQueueReceiver.java:124)
        at java.lang.Thread.run(Unknown Source)
Caused by: org.apache.activemq.kaha.RuntimeStoreException: java.io.IOException: 
Could not locate data file queue-data-1
        at 
org.apache.activemq.kaha.impl.MapContainerImpl.getValue(MapContainerImpl.java:340)
        at 
org.apache.activemq.kaha.impl.MapContainerImpl.remove(MapContainerImpl.java:265)
        at 
org.apache.activemq.store.kahadaptor.KahaMessageStore.removeMessage(KahaMessageStore.java:68)
        at 
org.apache.activemq.store.kahadaptor.KahaTransaction.commit(KahaTransaction.java:92)
        at 
org.apache.activemq.store.kahadaptor.KahaTransactionStore.commit(KahaTransactionStore.java:95)
        at 
org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:68)
        at 
org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:154)
        at 
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:92)
        at 
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:92)
        at 
org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:102)
        at 
org.apache.activemq.broker.AbstractConnection.processCommitTransactionOnePhase(AbstractConnection.java:330)
        at 
org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:99)
        at 
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:228)
        at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:63)
        at 
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
        at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
        at 
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:123)
        at 
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
        at 
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:127)
        ... 1 more
Caused by: java.io.IOException: Could not locate data file queue-data-1
        at 
org.apache.activemq.kaha.impl.DataManager.getDataFile(DataManager.java:117)
        at 
org.apache.activemq.kaha.impl.StoreDataReader.readItem(StoreDataReader.java:62)
        at 
org.apache.activemq.kaha.impl.DataManager.readItem(DataManager.java:121)
        at 
org.apache.activemq.kaha.impl.MapContainerImpl.getValue(MapContainerImpl.java:337)
        ... 20 more


-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: 
https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to