[jira] Updated: (AMQ-876) Kaha DB cannot locate queue data files

["Vadim Pesochinskiy (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/activemq/browse/AMQ-876?page=all ]

Vadim Pesochinskiy updated AMQ-876:
-----------------------------------

    Attachment: test.zip

I am not sure if you got my message or not. Since I am going to be away starting on Monday I am attaching the test and my e-mail.

"I was unable to write a simple unit test to recreate the problem, so I am attaching simulation test along with some utility classes. I am using IntelliJ Idea and JDK 1.5.2 installed. I am not sure if there is any 1.5 syntax. To run the test just start the broker (with kaha persistence) and execute DailyUpdateSimulationJmsTest JUnit class from Idea (Idea project file included). Sometimes it takes awhile before the error occurs (up to 5 minutes), but most of the time it happens very quickly. To check if error happened "grep" the AMQ log for "Could not locate data file" string. Thanks."

> 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
>         Assigned To: Rob Davies
>             Fix For: 4.1
>
>         Attachments: test.zip
>
>
> 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