This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 208f832905 [ISSUE#9160] Ensure the requestCode increments sequentially
208f832905 is described below
commit 208f832905e915547978d2eae674569925376d6e
Author: Matthew <[email protected]>
AuthorDate: Tue Jan 28 10:08:00 2025 +0800
[ISSUE#9160] Ensure the requestCode increments sequentially
---
.../java/org/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
*/