refactor(sparkplug): applies State pattern to SparkplugMqttClient, fi…

…xed onConnectionLost status reset Signed-off-by: Marcello Martina <[email protected]>
eclipse-kura · Feb 2, 2024 · d22484d · d22484d
1 parent 4fd0318
commit d22484d
Show file tree

Hide file tree

Showing 2 changed files with 224 additions and 137 deletions.
diff --git a/...ava/org/eclipse/kura/cloudconnection/sparkplug/mqtt/transport/SparkplugDataTransport.java b/...ava/org/eclipse/kura/cloudconnection/sparkplug/mqtt/transport/SparkplugDataTransport.java
@@ -230,8 +230,8 @@ public void removeDataTransportListener(DataTransportListener listener) {
     @Override
     public void connectionLost(Throwable arg0) {
         logger.info("{} - Connection lost", this.kuraServicePid);
+        this.client.handleConnectionLost();
         this.dataTransportListeners.forEach(listener -> callSafely(listener::onConnectionLost, arg0));
-
     }
 
     @Override