correct rust variables in new function

This commit is contained in:
Ollo 2025-04-18 21:42:08 +02:00
parent c8d4ab3ba3
commit 9d3dfda37e

View File

@ -669,13 +669,13 @@ fn main_function(parameter1: String, parameter2: Option<String>) -> ExitCode {
} }
fn fun_publishinfoviamqtt(mqtt_client: Option<AsyncClient>, straba_res: &NextDeparture) { fn fun_publishinfoviamqtt(mqtt_client: Option<AsyncClient>, straba_res: &NextDeparture) {
let topicInStation: String = format!("{}{}", GlobalConfiguration.mqttPrefix, "/inbound/station"); let topic_in_station: String = format!("{}{}", GlobalConfiguration.mqttPrefix, "/inbound/station");
let stationName: String = format!("{}", straba_res.inbound_station); let station_name: String = format!("{}", straba_res.inbound_station);
if (mqtt_client.is_some()) { if (mqtt_client.is_some()) {
publish_message(mqtt_client.unwrap(), topicInStation.as_str(), stationName.as_str()); publish_message(mqtt_client.unwrap(), topic_in_station.as_str(), station_name.as_str());
println!("MQTT published {:?} = {:?}s", topicInStation, straba_res.outbound_station); println!("MQTT published {:?} = {:?}s", topic_in_station, straba_res.outbound_station);
} else { } else {
println!("MQTT not ready... {:?} = {:?}s", topicInStation, straba_res.outbound_station); println!("MQTT not ready... {:?} = {:?}s", topic_in_station, straba_res.outbound_station);
} }
} }