From 967b81ac4536c997455a16452948d5451c7bba04 Mon Sep 17 00:00:00 2001 From: Marcello Martina Date: Fri, 2 Feb 2024 15:03:08 +0100 Subject: [PATCH] style: fixed typo Signed-off-by: Marcello Martina --- .../sparkplug/mqtt/transport/SparkplugMqttClient.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/kura/org.eclipse.kura.cloudconnection.sparkplug.mqtt.provider/src/main/java/org/eclipse/kura/cloudconnection/sparkplug/mqtt/transport/SparkplugMqttClient.java b/kura/org.eclipse.kura.cloudconnection.sparkplug.mqtt.provider/src/main/java/org/eclipse/kura/cloudconnection/sparkplug/mqtt/transport/SparkplugMqttClient.java index 12349576f9c..63bee4c268d 100644 --- a/kura/org.eclipse.kura.cloudconnection.sparkplug.mqtt.provider/src/main/java/org/eclipse/kura/cloudconnection/sparkplug/mqtt/transport/SparkplugMqttClient.java +++ b/kura/org.eclipse.kura.cloudconnection.sparkplug.mqtt.provider/src/main/java/org/eclipse/kura/cloudconnection/sparkplug/mqtt/transport/SparkplugMqttClient.java @@ -75,7 +75,7 @@ public class SparkplugMqttClient { private abstract class SessionStatus { - public abstract SessionStatus estabilishSession(boolean shouldConnectClient) throws KuraConnectException; + public abstract SessionStatus establishSession(boolean shouldConnectClient) throws KuraConnectException; public abstract SessionStatus terminateSession(boolean shouldDisconnectClient, long quiesceTimeout); @@ -218,7 +218,7 @@ private void setSocketFactory(String server) throws GeneralSecurityException, IO private class Terminated extends SessionStatus { @Override - public SessionStatus estabilishSession(boolean shouldConnectClient) throws KuraConnectException { + public SessionStatus establishSession(boolean shouldConnectClient) throws KuraConnectException { return toEstabilishing(shouldConnectClient); } @@ -237,7 +237,7 @@ public SessionStatus confirmSession() { private class Estabilishing extends SessionStatus { @Override - public SessionStatus estabilishSession(boolean shouldConnectClient) throws KuraConnectException { + public SessionStatus establishSession(boolean shouldConnectClient) throws KuraConnectException { return this; } @@ -256,7 +256,7 @@ public SessionStatus confirmSession() { private class Estabilished extends SessionStatus { @Override - public SessionStatus estabilishSession(boolean shouldConnectClient) throws KuraConnectException { + public SessionStatus establishSession(boolean shouldConnectClient) throws KuraConnectException { return this; } @@ -309,7 +309,7 @@ public synchronized void handleConnectionLost() { public synchronized void estabilishSession(boolean shouldConnectClient) throws KuraConnectException { logger.debug("Requested session estabilishment"); - doSessionTransition(this.sessionStatus.estabilishSession(shouldConnectClient)); + doSessionTransition(this.sessionStatus.establishSession(shouldConnectClient)); } public synchronized void terminateSession(boolean shouldDisconnectClient, long quiesceTimeout) {