activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aarvee <rvenkatara...@coremobility.com>
Subject AMQ 5.0.0 Kaha store crashes with 'Could not locate data file data-queue-data-1'
Date Tue, 08 Jan 2008 17:57:55 GMT

Hi,

I am using AMQ 5.0.0 stand alone broker with Kaha store (on quad processor
64 bit Linux machine)

In my test I have one producer sending a continuous stream of messages (each
just a ObjectMessage having one java.lang.Long), 

I have a client with 10 consumers, continuously reading off the queue. 

After a while (after about 75000 messages sent in this run, in about a
minute or so) I get the following errors and the broker never recovers, (
even after client or broker restart).

In the forums, I saw a similar error reported (but only during broker
restart) but apparently that was fixed in an earlier version.

Any ideas, how to get around this error ? 

Thanks for any help !




=============The server logs ====================================

ERROR DataManagerImpl                - Looking for key 1 but not found in
fileMa
p: {2=data-queue-data-2 number = 2 , length = 658 refCount = 2}
ERROR MapContainerImpl               - Failed to get value for offset=57324,
key
=(1, 5603425, 48), value=(1, 5603478, 291), previousItem=100317, nextItem=-1
java.io.IOException: Could not locate data file data-queue-data-1
        at
org.apache.activemq.kaha.impl.data.DataManagerImpl.getDataFile(DataMa
nagerImpl.java:129)
        at
org.apache.activemq.kaha.impl.data.SyncDataFileReader.readItem(SyncDa
taFileReader.java:65)
        at
org.apache.activemq.kaha.impl.data.DataManagerImpl.readItem(DataManag
erImpl.java:141)
        at
org.apache.activemq.kaha.impl.container.MapContainerImpl.getValue(Map
ContainerImpl.java:475)
        at
org.apache.activemq.store.kahadaptor.KahaMessageStore.recoverNextMess
ages(KahaMessageStore.java:166)
        at
org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(Proxy
MessageStore.java:83)
        at
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.fillBatc
h(QueueStorePrefetch.java:169)
        at
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.hasNext(
QueueStorePrefetch.java:109)
        at
org.apache.activemq.broker.region.cursors.StoreQueueCursor.hasNext(St
oreQueueCursor.java:129)
        at
org.apache.activemq.broker.region.Queue.buildList(Queue.java:1026)
        at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1009)
        at
org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:107
2)
        at
org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:1003)
        at
org.apache.activemq.broker.region.Queue$4.afterCommit(Queue.java:474)

        at
org.apache.activemq.transaction.Transaction.fireAfterCommit(Transacti
on.java:86)
        at
org.apache.activemq.transaction.LocalTransaction.commit(LocalTransact
ion.java:68)
        at
org.apache.activemq.broker.TransactionBroker.commitTransaction(Transa

=================================

===============When I restart broker  ==========================

INFO  KahaStore                      - Kaha Store using data directory
/home/ven
ky/localfs/kaha
ERROR MapContainerImpl               - Failed to load container
queue://example.
MyTestQueue
java.io.EOFException
        at java.io.RandomAccessFile.readFully(RandomAccessFile.java:383)
        at java.io.RandomAccessFile.readFully(RandomAccessFile.java:361)
        at
org.apache.activemq.kaha.impl.data.SyncDataFileReader.readItem(SyncDa
taFileReader.java:71)
        at
org.apache.activemq.kaha.impl.data.DataManagerImpl.readItem(DataManag
erImpl.java:141)
        at
org.apache.activemq.kaha.impl.container.MapContainerImpl.load(MapCont
ainerImpl.java:106)
        at
org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter.getMapCon
tainer(KahaPersistenceAdapter.java:212)
        at
org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter.createQue
ueMessageStore(KahaPersistenceAdapter.java:107)
        at
org.apache.activemq.broker.region.DestinationFactoryImpl.createDestin
ation(DestinationFactoryImpl.java:92)
        at
org.apache.activemq.broker.region.AbstractRegion.createDestination(Ab
stractRegion.java:399)

============= On the client =====================
Exception in thread "main" javax.jms.JMSException: POST COMMIT FAILED
        at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSuppo
rt.java:49)
        at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnect
ion.java:1178)
        at
org.apache.activemq.TransactionContext.commit(TransactionContext.java
:259)
        at
org.apache.activemq.ActiveMQSession.commit(ActiveMQSession.java:494)

-- 
View this message in context: http://www.nabble.com/AMQ-5.0.0-Kaha-store-crashes-with-%27Could-not-locate-data-file-data-queue-data-1%27-tp14694912s2354p14694912.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message