[rocketmq] branch develop updated: [ISSUE #6931] Set table reference the same object for setSubscriptionGroupTable method

[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 f76e8670b [ISSUE #6931] Set table reference the same object for 
setSubscriptionGroupTable method
f76e8670b is described below

commit f76e8670b09eda2f076eefba4f8bee8227f46707
Author: rongtong <jinrongto...@163.com>
AuthorDate: Fri Jun 23 11:31:16 2023 +0800

    [ISSUE #6931] Set table reference the same object for 
setSubscriptionGroupTable method
---
 .../rocketmq/broker/subscription/SubscriptionGroupManager.java     | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
index db8c8b6f2..0ae11313f 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
@@ -317,11 +317,8 @@ public class SubscriptionGroupManager extends 
ConfigManager {
         }
     }
 
-    public void setSubscriptionGroupTable(ConcurrentMap<String, 
SubscriptionGroupConfig> otherSubscriptionGroupTable) {
-        this.subscriptionGroupTable.clear();
-        for (String key : otherSubscriptionGroupTable.keySet()) {
-            this.subscriptionGroupTable.put(key, 
otherSubscriptionGroupTable.get(key));
-        }
+    public void setSubscriptionGroupTable(ConcurrentMap<String, 
SubscriptionGroupConfig> subscriptionGroupTable) {
+        this.subscriptionGroupTable = subscriptionGroupTable;
     }
 
     public boolean containsSubscriptionGroup(String group) {