Set table reference the same object for setSubscriptionGroupTable met…

…hod (#7204)
apache · Aug 22, 2023 · cc16a1b · cc16a1b
1 parent 72d796f
commit cc16a1b
Showing 1 changed file with 1 addition and 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
@@ -341,10 +341,7 @@ public void deleteSubscriptionGroupConfig(final String groupName) {
 
 
     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) {