From 4051e556902529d08b1ceebd2a514df256e2294c Mon Sep 17 00:00:00 2001 From: "Jan N. Klug" Date: Sat, 7 May 2022 12:04:34 +0200 Subject: [PATCH] Fix MQTT status message when disconnected while connecting Signed-off-by: Jan N. Klug --- .../openhab/core/io/transport/mqtt/MqttBrokerConnection.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/bundles/org.openhab.core.io.transport.mqtt/src/main/java/org/openhab/core/io/transport/mqtt/MqttBrokerConnection.java b/bundles/org.openhab.core.io.transport.mqtt/src/main/java/org/openhab/core/io/transport/mqtt/MqttBrokerConnection.java index e857917fd22..7688c37b562 100644 --- a/bundles/org.openhab.core.io.transport.mqtt/src/main/java/org/openhab/core/io/transport/mqtt/MqttBrokerConnection.java +++ b/bundles/org.openhab.core.io.transport.mqtt/src/main/java/org/openhab/core/io/transport/mqtt/MqttBrokerConnection.java @@ -162,10 +162,9 @@ public void onDisconnected(@Nullable MqttClientDisconnectedContext context) { public void onDisconnected(Throwable t) { cancelTimeoutFuture.run(); - - final MqttConnectionState connectionState = connection.connectionState(); future.complete(false); - connection.connectionObservers.forEach(o -> o.connectionStateChanged(connectionState, t)); + + connection.connectionObservers.forEach(o -> o.connectionStateChanged(MqttConnectionState.DISCONNECTED, t)); // If we tried to connect via start(), use the reconnect strategy to try it again if (connection.isConnecting) {