diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index a58e1bb23a76176222a475778900a199e88523c6..a59051c9e23ce117ce003846b5d8cf9cddfc9d62 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -141,9 +141,11 @@ public class MQTTVerticle extends AbstractVerticle { message.reply(false); return; } + callBackFuture.setHandler(result -> { - message.reply(true); + message.reply(result.result()); }); + vertx.setTimer(configuration.getMessageResponseTimeout(), timer -> { if (!callBackFuture.isComplete()) { dataEventsStatusCache.remove(model.getId().toString());