From bc12cb73a17e66377ef09d87e65a3bacbb0e64bb Mon Sep 17 00:00:00 2001 From: mapuo Date: Wed, 26 Jun 2019 14:26:14 +0300 Subject: [PATCH 1/2] reply with the result instead of true --- src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index a58e1bb..324bdc1 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -141,9 +141,9 @@ public class MQTTVerticle extends AbstractVerticle { message.reply(false); return; } - callBackFuture.setHandler(result -> { - message.reply(true); - }); + + callBackFuture.setHandler(message::reply); + vertx.setTimer(configuration.getMessageResponseTimeout(), timer -> { if (!callBackFuture.isComplete()) { dataEventsStatusCache.remove(model.getId().toString()); -- GitLab From 8aba966007c3e8be299baffd5d558402e172a453 Mon Sep 17 00:00:00 2001 From: mapuo Date: Wed, 26 Jun 2019 15:14:37 +0300 Subject: [PATCH 2/2] reply with the result instead of true --- src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 324bdc1..a59051c 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -142,7 +142,9 @@ public class MQTTVerticle extends AbstractVerticle { return; } - callBackFuture.setHandler(message::reply); + callBackFuture.setHandler(result -> { + message.reply(result.result()); + }); vertx.setTimer(configuration.getMessageResponseTimeout(), timer -> { if (!callBackFuture.isComplete()) { -- GitLab