From 49af0b2f2d2827fab82ce9a4c94373eaa02296d2 Mon Sep 17 00:00:00 2001 From: jarvis2f <137974272+jarvis2f@users.noreply.github.com> Date: Fri, 7 Feb 2025 21:00:51 +0800 Subject: [PATCH] =?UTF-8?q?=E2=9A=A1=EF=B8=8F=20fix:=20Fixed=20the=20`Prom?= =?UTF-8?q?ise`=20completion=20logic=20in=20the=20`stop`=20method.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/src/main/java/telegram/files/DataVerticle.java | 2 +- api/src/main/java/telegram/files/Start.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/api/src/main/java/telegram/files/DataVerticle.java b/api/src/main/java/telegram/files/DataVerticle.java index e98d534..f391bb0 100644 --- a/api/src/main/java/telegram/files/DataVerticle.java +++ b/api/src/main/java/telegram/files/DataVerticle.java @@ -82,12 +82,12 @@ public class DataVerticle extends AbstractVerticle { public void stop(Promise stopPromise) throws Exception { if (pool != null) { pool.close().onComplete(r -> { - stopPromise.complete(); if (r.succeeded()) { log.debug("Data verticle stopped!"); } else { log.error("Failed to close data verticle: %s".formatted(r.cause().getMessage())); } + stopPromise.complete(); }); } } diff --git a/api/src/main/java/telegram/files/Start.java b/api/src/main/java/telegram/files/Start.java index 17c3758..2d81ca3 100644 --- a/api/src/main/java/telegram/files/Start.java +++ b/api/src/main/java/telegram/files/Start.java @@ -64,6 +64,7 @@ public class Start { return; } vertx.undeploy(httpVerticle.deploymentID()) + .compose(r -> vertx.undeploy(dataVerticle.deploymentID())) .onComplete(res -> { if (res.succeeded()) { log.info("👋 Shutdown success");