Fix MQTT status message when disconnected while connecting (openhab#2951

) Signed-off-by: Jan N. Klug <github@klug.nrw>
ConnectorIO · May 20, 2022 · bf54474 · bf54474
1 parent fe5b1ed
commit bf54474
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...transport.mqtt/src/main/java/org/openhab/core/io/transport/mqtt/MqttBrokerConnection.java b/...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) {