Don't default to MQTT 3.1 either

This commit is contained in:
Nadja Reitzenstein 2022-02-15 18:28:58 +01:00
parent 337e8aa563
commit a7d30930ba

View File

@ -145,7 +145,6 @@ pub fn load(log: &Logger, config: &Config) -> Result<(ActorMap, Vec<Actor>)> {
}); });
let conn_opts = paho_mqtt::ConnectOptionsBuilder::new() let conn_opts = paho_mqtt::ConnectOptionsBuilder::new()
.keep_alive_interval(Duration::from_secs(20)) .keep_alive_interval(Duration::from_secs(20))
.clean_session(false)
.finalize(); .finalize();
let tok = mqtt.connect(conn_opts); let tok = mqtt.connect(conn_opts);
smol::block_on(tok)?; smol::block_on(tok)?;