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

…xed onConnectionLost status reset (#5114) * refactor(sparkplug): applies State pattern to SparkplugMqttClient, fixed onConnectionLost status reset Signed-off-by: Marcello Martina <[email protected]> * style: fixed typo Signed-off-by: Marcello Martina <[email protected]> * style: fixed establish typo Signed-off-by: Marcello Martina <[email protected]> --------- Signed-off-by: Marcello Martina <[email protected]>
eclipse-kura · Feb 3, 2024 · 7cac9e4 · 7cac9e4
1 parent 4fd0318
commit 7cac9e4
Show file tree

Hide file tree

Showing 2 changed files with 229 additions and 142 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
@@ -140,7 +140,7 @@ public void connect() throws KuraConnectException {
             throw new IllegalStateException("MQTT client is already connected");
         }
 
-        this.client.estabilishSession(true);
+        this.client.establishSession(true);
 
         stopExecutorService();
         this.executorService = Executors.newSingleThreadExecutor();
@@ -149,7 +149,7 @@ public void connect() throws KuraConnectException {
 
     @Override
     public boolean isConnected() {
-        return Objects.nonNull(this.client) && this.client.isSessionEstabilished();
+        return Objects.nonNull(this.client) && this.client.isSessionEstablished();
     }
 
     @Override
@@ -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