[rocketmq] branch develop updated: Set table reference the same object for setSubscriptionGroupTable method (#7204)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei 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 cc16a1b51 Set table reference the same object for 
setSubscriptionGroupTable method (#7204)
cc16a1b51 is described below

commit cc16a1b51216e1e80c22011b8b01e060bb4af8b3
Author: rongtong <jinrongto...@163.com>
AuthorDate: Tue Aug 22 10:42:25 2023 +0800

    Set table reference the same object for setSubscriptionGroupTable method 
(#7204)
---
 .../rocketmq/broker/subscription/SubscriptionGroupManager.java       | 5 +----
 1 file changed, 1 insertion(+), 4 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 74e39c0fe..e63b93058 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
@@ -341,10 +341,7 @@ public class SubscriptionGroupManager extends 
ConfigManager {
 
 
     public void setSubscriptionGroupTable(ConcurrentMap<String, 
SubscriptionGroupConfig> subscriptionGroupTable) {
-        this.subscriptionGroupTable.clear();
-        for (String key : subscriptionGroupTable.keySet()) {
-            putSubscriptionGroupConfig(subscriptionGroupTable.get(key));
-        }
+        this.subscriptionGroupTable = subscriptionGroupTable;
     }
 
     public boolean containsSubscriptionGroup(String group) {