Using stop(Promise) instead

quarkiverse · Aug 30, 2023 · 91b6a2c · 91b6a2c
1 parent fd29e13
commit 91b6a2c
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/runtime/src/main/java/io/quarkiverse/ironjacamar/runtime/IronJacamarVerticle.java b/runtime/src/main/java/io/quarkiverse/ironjacamar/runtime/IronJacamarVerticle.java
@@ -10,6 +10,7 @@
 import org.jboss.logging.Logger;
 
 import io.vertx.core.AbstractVerticle;
+import io.vertx.core.Promise;
 
 /**
  * A Vert.x {@link io.vertx.core.Verticle} that starts and stops a JCA {@link ResourceAdapter}.
@@ -41,10 +42,12 @@ public void start() throws Exception {
     }
 
     @Override
-    public void stop() {
+    public void stop(Promise<Void> stopPromise) {
         if (workManager != null) {
-            workManager.close().result();
+            workManager.close().andThen((v) -> ra.stop()).andThen(stopPromise);
+        } else {
+            ra.stop();
+            stopPromise.complete();
         }
-        ra.stop();
     }
 }