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.
