I restarted my stand alone persistent broker using KahaDB and I found this
error message bellow in the log, no more messages are being consumed or
forwarded. Advice? This is very high priority for me and quick help would be
really appreciated.
INFO | jvm 1 | 2012/09/18 23:13:50 | ERROR | Problem retrieving message
for browse
INFO | jvm 1 | 2012/09/18 23:13:50 | java.lang.RuntimeException:
java.lang.RuntimeException:
org.apache.activemq.protobuf.InvalidProtocolBufferException: Protocol
message contained an invalid tag (zero).
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:116)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.Queue.doBrowse(Queue.java:1069)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.Queue.expireMessages(Queue.java:822)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.Queue.access$100(Queue.java:96)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.Queue$2.run(Queue.java:136)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.thread.SchedulerTimerTask.run(SchedulerTimerTask.java:33)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
java.util.TimerThread.mainLoop(Timer.java:534)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
java.util.TimerThread.run(Timer.java:484)
INFO | jvm 1 | 2012/09/18 23:13:50 | Caused by:
java.lang.RuntimeException:
org.apache.activemq.protobuf.InvalidProtocolBufferException: Protocol
message contained an invalid tag (zero).
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:280)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:113)
INFO | jvm 1 | 2012/09/18 23:13:50 | ... 8 more
INFO | jvm 1 | 2012/09/18 23:13:50 | Caused by:
org.apache.activemq.protobuf.InvalidProtocolBufferException: Protocol
message contained an invalid tag (zero).
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:48)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.protobuf.CodedInputStream.readTag(CodedInputStream.java:75)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:110)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:7)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:184)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:213)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.protobuf.BaseMessage.mergeFramed(BaseMessage.java:237)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:938)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:1015)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$4.execute(KahaDBStore.java:556)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.kahadb.page.Transaction.execute(Transaction.java:769)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:545)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:106)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:97)
INFO | jvm 1 | 2012/09/18 23:13:50 | at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:277)
INFO | jvm 1 | 2012/09/18 23:13:50 | ... 9 more
The only config I have for KahaDB in my activemq.xml is the following:
<persistenceAdapter>
<kahaDB directory="/var/gluster/activemq/data/kahadb"/>
</persistenceAdapter>
Thanks in advance.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Broker-stuck-showing-error-messages-in-log-tp4656612.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
