mirror of
https://github.com/Telecominfraproject/wlan-cloud-opensync-controller.git
synced 2025-11-27 07:13:35 +00:00
changed log level for ovsdb client startup messages to info, provided more flexible SSL config for OpensyncMqttClient
This commit is contained in:
@@ -64,9 +64,33 @@ public class OpensyncMqttClient implements ApplicationListener<ContextClosedEven
|
||||
@Value("${connectus.mqttBroker.user:admin}")
|
||||
String username,
|
||||
@Value("${connectus.mqttBroker.password:admin}")
|
||||
String password
|
||||
String password,
|
||||
@Value("${mqtt.javax.net.ssl.keyStore:/opt/tip-wlan/certs/client_keystore.jks}")
|
||||
String jdkKeyStoreLocation,
|
||||
@Value("${mqtt.javax.net.ssl.keyStorePassword:mypassword}")
|
||||
String jdkKeyStorePassword,
|
||||
@Value("${mqtt.javax.net.ssl.trustStore:/opt/tip-wlan/certs/truststore.jks}")
|
||||
String jdkTrustStoreLocation,
|
||||
@Value("${mqtt.javax.net.ssl.trustStorePassword:mypassword}")
|
||||
String jdkTrustStorePassword
|
||||
){
|
||||
|
||||
if(System.getProperty("javax.net.ssl.keyStore") == null) {
|
||||
System.setProperty("javax.net.ssl.keyStore", jdkKeyStoreLocation);
|
||||
}
|
||||
|
||||
if(System.getProperty("javax.net.ssl.keyStorePassword") == null) {
|
||||
System.setProperty("javax.net.ssl.keyStorePassword", jdkKeyStorePassword);
|
||||
}
|
||||
|
||||
if(System.getProperty("javax.net.ssl.trustStore") == null) {
|
||||
System.setProperty("javax.net.ssl.trustStore", jdkTrustStoreLocation);
|
||||
}
|
||||
|
||||
if(System.getProperty("javax.net.ssl.trustStorePassword") == null) {
|
||||
System.setProperty("javax.net.ssl.trustStorePassword", jdkTrustStorePassword);
|
||||
}
|
||||
|
||||
Runnable mqttClientRunnable = () -> {
|
||||
while(keepReconnecting) {
|
||||
BlockingConnection connection = null;
|
||||
|
||||
@@ -174,7 +174,7 @@ public class ConnectusOvsdbClient implements ConnectusOvsdbClientInterface {
|
||||
|
||||
listener.startListeningWithSsl(ovsdbListenPort, sslContext, connectionCallback).join();
|
||||
|
||||
LOG.debug("manager waiting for connection on port {}...", ovsdbListenPort);
|
||||
LOG.info("manager waiting for connection on port {}...", ovsdbListenPort);
|
||||
}
|
||||
|
||||
private ConnectNodeInfo processConnectRequest(OvsdbClient ovsdbClient, String clientCn,
|
||||
|
||||
@@ -79,7 +79,7 @@ public class ConnectusOvsdbRedirector {
|
||||
|
||||
listener.startListeningWithSsl(ovsdbRedirectorListenPort, sslContext, connectionCallback).join();
|
||||
|
||||
LOG.debug("redirector waiting for connection on port {} ...", ovsdbRedirectorListenPort);
|
||||
LOG.info("redirector waiting for connection on port {} ...", ovsdbRedirectorListenPort);
|
||||
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user