lupine/solax2mqtt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Try to be a bit more resilient mqtt-side

Browse Source
This commit is contained in:
Nick Thomas
2022-10-16 17:44:42 +01:00
parent 672798197b
commit 146980f5da
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main.rs
View File

@@ -182,6 +182,7 @@ fn mqtt_connect(uri: String, client_id: String) -> Result<mqtt::Client, mqtt::Er
let mqtt_opts = mqtt::CreateOptionsBuilder::new() let mqtt_opts = mqtt::CreateOptionsBuilder::new()
.server_uri(uri) .server_uri(uri)
.client_id(client_id) .client_id(client_id)
.send_while_disconnected(false)
.finalize(); .finalize();
// Create a client. // Create a client.
@@ -189,7 +190,7 @@ fn mqtt_connect(uri: String, client_id: String) -> Result<mqtt::Client, mqtt::Er
// Define the set of options for the connection. // Define the set of options for the connection.
let mqtt_conn_opts = mqtt::ConnectOptionsBuilder::new() let mqtt_conn_opts = mqtt::ConnectOptionsBuilder::new()
.keep_alive_interval(Duration::from_secs(20)) .keep_alive_interval(Duration::from_secs(5))
.clean_session(true) .clean_session(true)
.finalize(); .finalize();
@@ -245,6 +246,8 @@ fn main() {
let mqtt_client = mqtt_connect(flags.mqtt_url, mqtt_client_id).unwrap(); let mqtt_client = mqtt_connect(flags.mqtt_url, mqtt_client_id).unwrap();
// TODO: Publish Home Assistant autodiscovery message (retained)
loop { loop {
match gather(&solax_url, &flags.solax_password) { match gather(&solax_url, &flags.solax_password) {
Ok(msg) => { Ok(msg) => {