Add MQTT authorization

dvdgeisler · Nov 24, 2022 · 40d69c1 · 40d69c1
1 parent 94f2ab6
commit 40d69c1
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/dirigera-client-mqtt/src/main/java/de/dvdgeisler/iot/dirigera/client/mqtt/MqttBridge.java b/dirigera-client-mqtt/src/main/java/de/dvdgeisler/iot/dirigera/client/mqtt/MqttBridge.java
@@ -22,6 +22,8 @@ public class MqttBridge extends org.eclipse.paho.client.mqttv3.MqttClient {
     public MqttBridge(
             @Value("${dirigera.mqtt.hostname:localhost}") final String host,
             @Value("${dirigera.mqtt.port:1883}") final Short port,
+            @Value("${dirigera.mqtt.username:}") final String username,
+            @Value("${dirigera.mqtt.password:}") final String password,
             @Value("${dirigera.mqtt.reconnect:true}") final Boolean reconnect,
             @Value("${dirigera.mqtt.timeout:10}") final Integer timeout,
             final DirigeraApi api) throws MqttException {
@@ -38,6 +40,11 @@ public MqttBridge(
         options.setAutomaticReconnect(reconnect);
         options.setCleanSession(true);
         options.setConnectionTimeout(timeout);
+
+        if (!username.isEmpty() && !password.isEmpty()) {
+            options.setUserName(username);
+            options.setPassword(password.toCharArray());
+        }
         this.connect(options);
 
         log.info("Connection to MQTT broker successfully established");

diff --git a/dirigera-client-mqtt/src/main/resources/application.properties b/dirigera-client-mqtt/src/main/resources/application.properties
@@ -1,4 +1,4 @@
-spring.application.name=Dirigera Dump
+spring.application.name=Dirigera MQTT
 logging.level.root=error
 logging.level.de.dvdgeisler.iot.dirigera=debug
 spring.main.web-application-type=none