This is an automated email from the ASF dual-hosted git repository. zhouxzhan pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 64dbc26950e27178332e5ad4e675f531912396ac Author: nowinkey <[email protected]> AuthorDate: Fri Feb 10 20:17:30 2023 +0800 Add case MESSAGE_MAGIC_CODE_V2 --- .../src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 788f1d6d6..ba4b53064 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -3030,9 +3030,10 @@ public class DefaultMessageStore implements MessageStore { int magicCode = byteBuffer.getInt(); switch (magicCode) { - case CommitLog.MESSAGE_MAGIC_CODE: + case MessageDecoder.MESSAGE_MAGIC_CODE: + case MessageDecoder.MESSAGE_MAGIC_CODE_V2: break; - case CommitLog.BLANK_MAGIC_CODE: + case MessageDecoder.BLANK_MAGIC_CODE: totalSize = 0; break; default:
