Fix race condition in test and disable another SSE test (see quarkusi…

…o#16227)
cescoffier · Apr 7, 2021 · dfe34cf · dfe34cf
1 parent aecb85e
commit dfe34cf
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...ent/src/test/java/io/quarkus/resteasy/reactive/jsonb/deployment/test/sse/SseTestCase.java b/...ent/src/test/java/io/quarkus/resteasy/reactive/jsonb/deployment/test/sse/SseTestCase.java
@@ -20,6 +20,7 @@
 import org.jboss.resteasy.reactive.client.impl.MultiInvoker;
 import org.jboss.shrinkwrap.api.ShrinkWrap;
 import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
@@ -79,6 +80,7 @@ public void testMultiFromSse() {
     }
 
     @Test
+    @Disabled("See https://github.com/quarkusio/quarkus/issues/16227")
     public void testMultiFromMulti() {
         testMulti("sse/multi");
     }

diff --git a/...java/io/quarkus/smallrye/reactivemessaging/amqp/devmode/nohttp/AmqpDevModeNoHttpTest.java b/...java/io/quarkus/smallrye/reactivemessaging/amqp/devmode/nohttp/AmqpDevModeNoHttpTest.java
@@ -4,6 +4,7 @@
 import static org.awaitility.Awaitility.await;
 
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.TimeUnit;
 import java.util.logging.LogRecord;
 import java.util.stream.Collectors;
@@ -76,7 +77,7 @@ public void testProducerUpdate() {
     @Test
     public void testConsumerUpdate() {
         await().atMost(1, TimeUnit.MINUTES).untilAsserted(() -> {
-            List<LogRecord> log = TEST.getLogRecords();
+            List<LogRecord> log = new CopyOnWriteArrayList<>(TEST.getLogRecords());
             assertThat(log).hasSizeGreaterThanOrEqualTo(5);
 
             List<Long> nums = log.stream()