activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: AMQ 5.0.0 Kaha store crashes with 'Could not locate data file data-queue-data-1'
Date Wed, 09 Jan 2008 17:30:34 GMT
please use the default store for activemq 5.0 - amqstore. It  
supersedes the kaha store originally using kaha. The difference is  
that we've integrated the journal with kaha - and this is the main  
store we test on.

cheers,

Rob


Rob Davies
'Go further faster with Apache Camel!'
http://rajdavies.blogspot.com/




On Jan 8, 2008, at 5:57 PM, aarvee wrote:

>
> 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