(rocketmq) branch develop updated: [ISSUE #7851] Fix hashcode and equals methods of SubscriptionGroupConfig

[jinrongtong]

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 471dbc01bf [ISSUE #7851] Fix hashcode and equals methods of 
SubscriptionGroupConfig
471dbc01bf is described below

commit 471dbc01bff30db0492c2ab6993d398faa393410
Author: Qiping Luo <rocky55...@163.com>
AuthorDate: Tue Feb 27 16:49:20 2024 +0800

    [ISSUE #7851] Fix hashcode and equals methods of SubscriptionGroupConfig
---
 .../remoting/protocol/subscription/SubscriptionGroupConfig.java         | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java
index 5522059aaf..85cbce9b6a 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java
@@ -182,6 +182,7 @@ public class SubscriptionGroupConfig {
         result = prime * result + (consumeEnable ? 1231 : 1237);
         result = prime * result + (consumeFromMinEnable ? 1231 : 1237);
         result = prime * result + (notifyConsumerIdsChangedEnable ? 1231 : 
1237);
+        result = prime * result + (consumeMessageOrderly ? 1231 : 1237);
         result = prime * result + ((groupName == null) ? 0 : 
groupName.hashCode());
         result = prime * result + retryMaxTimes;
         result = prime * result + retryQueueNums;
@@ -208,6 +209,7 @@ public class SubscriptionGroupConfig {
             .append(consumeEnable, other.consumeEnable)
             .append(consumeFromMinEnable, other.consumeFromMinEnable)
             .append(consumeBroadcastEnable, other.consumeBroadcastEnable)
+            .append(consumeMessageOrderly, other.consumeMessageOrderly)
             .append(retryQueueNums, other.retryQueueNums)
             .append(retryMaxTimes, other.retryMaxTimes)
             .append(whichBrokerWhenConsumeSlowly, 
other.whichBrokerWhenConsumeSlowly)