test: properly close vertx instances

quarkusio · Nov 20, 2019 · 91d56d1 · 91d56d1
1 parent a454a08
commit 91d56d1
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/extensions/mailer/runtime/src/test/java/io/quarkus/mailer/runtime/MailerImplTest.java b/extensions/mailer/runtime/src/test/java/io/quarkus/mailer/runtime/MailerImplTest.java
@@ -48,7 +48,7 @@ static void startWiser() {
     @AfterAll
     static void stopWiser() {
         wiser.stop();
-        vertx.close();
+        vertx.close().toCompletableFuture().join();
     }
 
     @BeforeEach

diff --git a/extensions/mailer/runtime/src/test/java/io/quarkus/mailer/runtime/MockMailerImplTest.java b/extensions/mailer/runtime/src/test/java/io/quarkus/mailer/runtime/MockMailerImplTest.java
@@ -32,7 +32,7 @@ static void start() {
 
     @AfterAll
     static void stop() {
-        vertx.close();
+        vertx.close().toCompletableFuture().join();
     }
 
     @BeforeEach

diff --git a/...ation-tests/vertx-graphql/src/test/java/io/quarkus/vertx/graphql/it/VertxGraphqlTest.java b/...ation-tests/vertx-graphql/src/test/java/io/quarkus/vertx/graphql/it/VertxGraphqlTest.java
@@ -4,6 +4,7 @@
 import static org.hamcrest.CoreMatchers.is;
 
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
 import org.eclipse.microprofile.config.ConfigProvider;
@@ -32,8 +33,10 @@ public static void initializeVertx() {
     }
 
     @AfterAll
-    public static void closeVertx() {
-        vertx.close();
+    public static void closeVertx() throws InterruptedException {
+        CountDownLatch latch = new CountDownLatch(1);
+        vertx.close((h) -> latch.countDown());
+        latch.await();
     }
 
     @Test