activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pollotek <claudio.sant...@gmail.com>
Subject Re: KahaDB corruption
Date Thu, 20 Sep 2012 20:18:46 GMT
I have the same issue with ActiveMQ 5.6.0

I started to get the following messages in the log after bouncing ActiveMQ
stand alone broker:

2012-09-20 20:09:58,748 | ERROR |
org.apache.activemq.broker.region.cursors.QueueStorePrefetch@18287811:com.xxxx.queue.timedData,batchResetNeeded=false,storeHasMessages=true,size=22772,cacheEnabled=false
- Failed to fill batch |
org.apache.activemq.broker.region.cursors.AbstractStoreCursor |
Queue:com.xxxxt.queue.timedData
java.lang.RuntimeException:
org.apache.activemq.protobuf.InvalidProtocolBufferException: Protocol
message contained an invalid tag (zero).
	at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:280)
	at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:113)
	at
org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157)
	at
org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1766)
	at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1995)
	at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1488)
	at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
	at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
Caused by: org.apache.activemq.protobuf.InvalidProtocolBufferException:
Protocol message contained an invalid tag (zero).
	at
org.apache.activemq.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:48)
	at
org.apache.activemq.protobuf.CodedInputStream.readTag(CodedInputStream.java:75)
	at
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:110)
	at
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:7)
	at
org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:184)
	at
org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:213)
	at
org.apache.activemq.protobuf.BaseMessage.mergeFramed(BaseMessage.java:237)
	at
org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:938)
	at
org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:1015)
	at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$4.execute(KahaDBStore.java:556)
	at org.apache.kahadb.page.Transaction.execute(Transaction.java:769)
	at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:545)
	at
org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:106)
	at
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:97)
	at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:277)
	... 7 more
2012-09-20 20:09:58,748 | ERROR | Failed to page in more queue messages  |
org.apache.activemq.broker.region.Queue | Queue:com.xxxxt.queue.timedData
java.lang.RuntimeException: java.lang.RuntimeException:
org.apache.activemq.protobuf.InvalidProtocolBufferException: Protocol
message contained an invalid tag (zero).
	at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:116)
	at
org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157)
	at
org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1766)
	at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1995)
	at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1488)
	at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
	at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
Caused by: java.lang.RuntimeException:
org.apache.activemq.protobuf.InvalidProtocolBufferException: Protocol
message contained an invalid tag (zero).
	at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:280)
	at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:113)
	... 6 more
Caused by: org.apache.activemq.protobuf.InvalidProtocolBufferException:
Protocol message contained an invalid tag (zero).
	at
org.apache.activemq.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:48)
	at
org.apache.activemq.protobuf.CodedInputStream.readTag(CodedInputStream.java:75)
	at
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:110)
	at
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:7)
	at
org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:184)
	at
org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:213)
	at
org.apache.activemq.protobuf.BaseMessage.mergeFramed(BaseMessage.java:237)
	at
org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:938)
	at
org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:1015)
	at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$4.execute(KahaDBStore.java:556)
	at org.apache.kahadb.page.Transaction.execute(Transaction.java:769)
	at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:545)
	at
org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:106)
	at
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:97)
	at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:277)
	... 7 more

This is my kahadb configuration:

        <persistenceAdapter>
            <kahaDB directory="/var/gluster/activemq/data/kahadb"
                    ignoreMissingJournalfiles="true"
                    checkForCorruptJournalFiles="true"
                    checksumJournalFiles="true"/>
        </persistenceAdapter>





--
View this message in context: http://activemq.2283324.n4.nabble.com/KahaDB-corruption-tp3321382p4656773.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message