scottk/wlan-cloud-opensync-controller
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-opensync-controller.git synced 2025-11-03 12:08:07 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

corrected log output

Browse Source
This commit is contained in:
DTop
2020-03-10 14:38:55 -04:00
parent f752a26a6b
commit b6042443c0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
opensync-gateway/src/main/java/com/telecominfraproject/wlan/opensync/mqtt/OpensyncMqttClient.java
View File

@@ -98,7 +98,7 @@ public class OpensyncMqttClient implements ApplicationListener<ContextClosedEven
MQTT mqtt = new MQTT(); MQTT mqtt = new MQTT();
//mqtt.setHost("tcp://192.168.0.137:61616"); //mqtt.setHost("tcp://192.168.0.137:61616");
mqtt.setHost("tls://"+mqttBrokerAddress+":"+mqttBrokerListenPort); mqtt.setHost("tls://"+mqttBrokerAddress+":"+mqttBrokerListenPort);
LOG.info("Connecting to Artemis using MQTT at {}", mqtt.getHost()); LOG.info("Connecting to MQTT broker at {}", mqtt.getHost());
mqtt.setClientId("opensync_mqtt"); mqtt.setClientId("opensync_mqtt");
mqtt.setUserName(username); mqtt.setUserName(username);
mqtt.setPassword(password); mqtt.setPassword(password);
@@ -109,7 +109,7 @@ public class OpensyncMqttClient implements ApplicationListener<ContextClosedEven
//TODO: revisit this blocking connection, change it to futureConnection //TODO: revisit this blocking connection, change it to futureConnection
connection = mqtt.blockingConnection(); connection = mqtt.blockingConnection();
connection.connect(); connection.connect();
LOG.info("Connected to Artemis cluster at {}", mqtt.getHost()); LOG.info("Connected to MQTT broker at {}", mqtt.getHost());
// Subscribe to topics: // Subscribe to topics:
// //