Merge pull request #14245 from cescoffier/fix-cme-in-reactive-messagi…

…ng-tests Fix concurrency modification exception in Reactive Messaging tests
quarkusio · Jan 12, 2021 · 1268f72 · 1268f72
2 parents d0ed9c6 + c04f0fe
commit 1268f72
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...rc/test/java/io/quarkus/smallrye/reactivemessaging/blocking/beans/InfiniteSubscriber.java b/...rc/test/java/io/quarkus/smallrye/reactivemessaging/blocking/beans/InfiniteSubscriber.java
@@ -1,7 +1,7 @@
 package io.quarkus.smallrye.reactivemessaging.blocking.beans;
 
-import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 import javax.enterprise.context.ApplicationScoped;
 
@@ -12,8 +12,8 @@
 @ApplicationScoped
 public class InfiniteSubscriber {
 
-    private final List<Integer> payloads = new ArrayList<>();
-    private final List<Integer> messages = new ArrayList<>();
+    private final List<Integer> payloads = new CopyOnWriteArrayList<>();
+    private final List<Integer> messages = new CopyOnWriteArrayList<>();
 
     @Incoming("infinite-producer-payload")
     public SubscriberBuilder<Integer, Void> consumeFourItems() {