bugfix: solve the concurrency problem in ruleTransfer

apache · Jul 30, 2023 · da33c12 · da33c12
1 parent f1a5039
commit da33c12
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java b/...src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java
@@ -24,6 +24,7 @@
 import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CopyOnWriteArrayList;
 import javax.annotation.PostConstruct;
 import org.apache.commons.collections.MapUtils;
 import org.apache.rocketmq.eventbridge.adapter.runtime.boot.common.CirculatorContext;
@@ -67,7 +68,7 @@ public void init() {
 
     @Override
     public void run() {
-        List<ConnectRecord> afterTransformConnect= Lists.newArrayList();
+        List<ConnectRecord> afterTransformConnect = new CopyOnWriteArrayList<>();;
         while (!stopped) {
             try {
                 Map<String, List<ConnectRecord>> eventRecordMap = circulatorContext.takeEventRecords(batchSize);