diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index df65a9938ad587140e08bdaa973e6245fe24e430..a58e1bb23a76176222a475778900a199e88523c6 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -100,7 +100,7 @@ public class MQTTVerticle extends AbstractVerticle { client.connect(configuration.getPort(), configuration.getHost(), ch -> { if (ch.succeeded()) { log.debug("Connected to a server"); - client.subscribe(configuration.getTopic(), 0); + // client.subscribe(configuration.getTopic(), 0); event.complete(); } else { log.error("Failed to connect to a server!", ch.cause());