From 9003b47e538ce620443908526e0abd1db1e446fa Mon Sep 17 00:00:00 2001 From: Matthew Date: Tue, 28 Jan 2025 10:08:00 +0800 Subject: [PATCH] [ISSUE#9160] Ensure the requestCode increments sequentially --- .../apache/rocketmq/remoting/protocol/RequestCode.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java index e3b180a537..9cbbe83490 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java @@ -213,6 +213,10 @@ public class RequestCode { public static final int PUSH_REPLY_MESSAGE_TO_CLIENT = 326; public static final int ADD_WRITE_PERM_OF_BROKER = 327; + + public static final int GET_ALL_PRODUCER_INFO = 328; + + public static final int DELETE_EXPIRED_COMMITLOG = 329; public static final int GET_TOPIC_CONFIG = 351; @@ -246,10 +250,6 @@ public class RequestCode { public static final int RESET_MASTER_FLUSH_OFFSET = 908; - public static final int GET_ALL_PRODUCER_INFO = 328; - - public static final int DELETE_EXPIRED_COMMITLOG = 329; - /** * Controller code */