Details
-
Bug
-
Resolution: Done
-
Major
-
None
-
None
Description
When a sequence of "000000" are read in from the store (in error) the broker will assume this is KahaTraceCommand and throws a ClassCastException when it is tried to be cast to a KahaAddCommand. Because it is a ClassCastException it slips out of the org.apache.activemq.store.kahadb.KahaDBStore.loadMessage() and does not invoke the IOExceptionHandler.
| ERROR | Failed to page in more queue messages | org.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[XXXXX] Task-300 java.lang.RuntimeException: java.lang.RuntimeException: java.lang.ClassCastException: org.apache.activemq.store.kahadb.data.KahaTraceCommand cannot be cast to org.apache.activemq.store.kahadb.data.KahaAddMessageCommand at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:145) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:159) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1895) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2116) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1581) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133) [activemq-client-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48) [activemq-client-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [?:1.8.0_91] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [?:1.8.0_91] at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91] Caused by: java.lang.RuntimeException: java.lang.ClassCastException: org.apache.activemq.store.kahadb.data.KahaTraceCommand cannot be cast to org.apache.activemq.store.kahadb.data.KahaAddMessageCommand at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:384) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:142) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] ... 9 more Caused by: java.lang.ClassCastException: org.apache.activemq.store.kahadb.data.KahaTraceCommand cannot be cast to org.apache.activemq.store.kahadb.data.KahaAddMessageCommand at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:1132) ~[activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:595) ~[activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transaction.java:779) ~[activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:584) ~[activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:105) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:105) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:109) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:381) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:142) ~[activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] ... 9 more
However when a slightly different bad sequence of bytes are loaded from the kahadb file incorrect sequence is detected at load time and invokes the IOExceptionHandler .
ERROR | Failed to load message at: 1084:12816246 | org.apache.activemq.store.kahadb.KahaDBStore | ActiveMQ BrokerService[il3-broker-c-12-vz200] Task-702 org.apache.activemq.protobuf.InvalidProtocolBufferException: Protocol message contained an invalid tag (zero). at org.apache.activemq.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:48) ~[activemq-protobuf-1.1.jar:1.1] at org.apache.activemq.protobuf.CodedInputStream.readTag(CodedInputStream.java:75) ~[activemq-protobuf-1.1.jar:1.1] at org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:110) ~[activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.mergeUnframed(KahaAddMessageCommand.java:7) ~[activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:184) ~[activemq-protobuf-1.1.jar:1.1] at org.apache.activemq.protobuf.BaseMessage.mergeUnframed(BaseMessage.java:213) ~[activemq-protobuf-1.1.jar:1.1] at org.apache.activemq.protobuf.BaseMessage.mergeFramed(BaseMessage.java:237) ~[activemq-protobuf-1.1.jar:1.1] at org.apache.activemq.store.kahadb.MessageDatabase.load(MessageDatabase.java:1071) ~[activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:1125) [activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:595) [activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transaction.java:779) [activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:584) [activemq-kahadb-store-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:105) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:105) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:109) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:381) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:142) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:159) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1895) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2116) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1581) [activemq-broker-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133) [activemq-client-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48) [activemq-client-5.11.0.redhat-621159.jar:5.11.0.redhat-621159] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [?:1.8.0_91] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [?:1.8.0_91] at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
Can the broker handle these invalid data exception scenarios in a consistent way.
