Extend the timeout of the testThatEventConsumersAreCalledOnDuplicated…

…Context and testThatBlockingEventConsumersAreCalledOnDuplicatedContext as the are failing on the windows CI
quarkusio · Sep 28, 2022 · 06d6e6e · 06d6e6e
1 parent 1a2504a
commit 06d6e6e
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/extensions/vertx/deployment/src/test/java/io/quarkus/vertx/DuplicatedContextTest.java b/extensions/vertx/deployment/src/test/java/io/quarkus/vertx/DuplicatedContextTest.java
@@ -7,7 +7,6 @@
 import java.util.List;
 import java.util.UUID;
 import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.atomic.AtomicInteger;
 
 import javax.enterprise.context.ApplicationScoped;
 import javax.inject.Inject;
@@ -68,7 +67,6 @@ public void cleanup() {
 
     @Test
     public void testThatMessageSentToTheEventBusAreProcessedOnUnsharedDuplicatedContext() {
-        AtomicInteger expected = new AtomicInteger();
         String id1 = UUID.randomUUID().toString();
         bus.send("context-send", id1);
         await().until(() -> consumers.probes().contains(id1));
@@ -112,7 +110,7 @@ bus.<String> request("context", uuid)
 
         Uni.join().all(unis).andFailFast()
                 .runSubscriptionOn(Infrastructure.getDefaultExecutor())
-                .await().atMost(Duration.ofSeconds(10));
+                .await().atMost(Duration.ofSeconds(30));
     }
 
     @Test
@@ -133,7 +131,7 @@ bus.<String> request("context-blocking", uuid)
 
         Uni.join().all(unis).andFailFast()
                 .runSubscriptionOn(Infrastructure.getDefaultExecutor())
-                .await().atMost(Duration.ofSeconds(10));
+                .await().atMost(Duration.ofSeconds(30));
 
     }