diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 2176b9f5aa9c59ddb6ba7aa39122ae83a7a92c90..8ec1003414a06e68ba23ce7e65cd005a9d419590 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -46,7 +46,7 @@ public class MQTTVerticle extends AbstractVerticle { clientOptions = new MqttClientOptions() .setAutoKeepAlive(keepAliveEnabled) .setKeepAliveTimeSeconds(configuration.getKeepAliveInterval()) - .setCleanSession(false) + .setCleanSession(true) .setClientId(configuration.getClientId()); }