Skip to content

Commit 1b47b2f

Browse files
authored
MQTT: avoid duplicate connect attempts (#3039)
1 parent 60e196e commit 1b47b2f

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

io.openems.edge.controller.api.mqtt/src/io/openems/edge/controller/api/mqtt/ControllerApiMqttImpl.java

+2-6
Original file line numberDiff line numberDiff line change
@@ -91,11 +91,7 @@ private void activate(ComponentContext context, Config config) throws Exception
9191
this.topicPrefix = createTopicPrefix(config);
9292

9393
super.activate(context, config.id(), config.alias(), config.enabled());
94-
this.mqttConnector.connect(config.uri(), config.clientId(), config.username(), config.password(),
95-
config.certPem(), config.privateKeyPem(), config.trustStorePem()).thenAccept(client -> {
96-
this.mqttClient = client;
97-
this.logInfo(this.log, "Connected to MQTT Broker [" + config.uri() + "]");
98-
});
94+
9995
this.scheduleReconnect();
10096
}
10197

@@ -152,7 +148,7 @@ protected void logInfo(Logger log, String message) {
152148

153149
@Override
154150
protected void logWarn(Logger log, String message) {
155-
super.logInfo(log, message);
151+
super.logWarn(log, message);
156152
}
157153

158154
@Override

0 commit comments

Comments
 (0)