Make MQTT Port configurable

Implements issue #12.
DennisOSRM · Nov 5, 2023 · 6fe78e6 · 6fe78e6
1 parent 6c6421f
commit 6fe78e6
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/src/main.rs b/src/main.rs
@@ -24,6 +24,8 @@ struct Cli {
     mqtt_broker_host: String,
     mqtt_username: Option<String>,
     mqtt_password: Option<String>,
+    #[clap(default_value = "1883")]
+    mqtt_broker_port: u16,
 }
 
 static REQUEST_DELAY: u64 = 30_500;
@@ -56,6 +58,7 @@ fn main() {
         &cli.mqtt_broker_host,
         &cli.mqtt_username,
         &cli.mqtt_password,
+        cli.mqtt_broker_port,
     );
 
     loop {

diff --git a/src/mqtt.rs b/src/mqtt.rs
@@ -14,8 +14,13 @@ pub struct Mqtt {
 }
 
 impl Mqtt {
-    pub fn new(host: &str, username: &Option<String>, password: &Option<String>) -> Self {
-        let mut mqttoptions = MqttOptions::new("hms800wt2-mqtt-publisher", host, 1883);
+    pub fn new(
+        host: &str,
+        username: &Option<String>,
+        password: &Option<String>,
+        port: u16,
+    ) -> Self {
+        let mut mqttoptions = MqttOptions::new("hms800wt2-mqtt-publisher", host, port);
         mqttoptions.set_keep_alive(Duration::from_secs(5));
 
         //parse the mqtt authentication options