feat: Reconnect to mqtt when connection is lost
This commit is contained in:
@@ -26,6 +26,7 @@ impl From<MqttConfig> for MqttOptions {
|
|||||||
let mut mqtt_options = MqttOptions::new(value.client_name, (value.host, value.port));
|
let mut mqtt_options = MqttOptions::new(value.client_name, (value.host, value.port));
|
||||||
mqtt_options.set_credentials(value.username, value.password);
|
mqtt_options.set_credentials(value.username, value.password);
|
||||||
mqtt_options.set_keep_alive(5);
|
mqtt_options.set_keep_alive(5);
|
||||||
|
mqtt_options.set_session_mode(rumqttc::SessionMode::Persistent);
|
||||||
|
|
||||||
if value.tls {
|
if value.tls {
|
||||||
mqtt_options.set_transport(Transport::tls_with_default_config());
|
mqtt_options.set_transport(Transport::tls_with_default_config());
|
||||||
|
|||||||
Reference in New Issue
Block a user