feat: FSM 2

Author: caoccao

hivemq-edge/src/main/java/com/hivemq/protocols/fsm/ProtocolAdapterTransition.java renamed to hivemq-edge/src/main/java/com/hivemq/protocols/fsm/ClassLoaderUtils.java

@@ -18,9 +18,21 @@
 
 import org.jetbrains.annotations.NotNull;
 
-public interface ProtocolAdapterTransition {
-    @NotNull ProtocolAdapterTransitionResponse transition(
-            final @NotNull ProtocolAdapterState toState,
-            final @NotNull ProtocolAdapterInstance session,
-            final @NotNull ProtocolAdapterTransitionRequest request);
+import java.util.function.Supplier;
+
+public final class ClassLoaderUtils {
+    private ClassLoaderUtils() {
+    }
+
+    public static <T> @NotNull T runWithContextLoader(
+            final @NotNull ClassLoader contextLoader,
+            final @NotNull Supplier<T> wrapperSupplier) {
+        final ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
+        try {
+            Thread.currentThread().setContextClassLoader(contextLoader);
+            return wrapperSupplier.get();
+        } finally {
+            Thread.currentThread().setContextClassLoader(contextClassLoader);
+        }
+    }
 }

hivemq-edge/src/main/java/com/hivemq/protocols/fsm/I18nProtocolAdapterMessage.java

@@ -26,6 +26,8 @@ public enum I18nProtocolAdapterMessage implements I18nError {
     FSM_TRANSITION_FAILURE_UNABLE_TO_TRANSITION_FROM_STATE_TO_STATE,
     FSM_TRANSITION_SUCCESS_STATE_IS_UNCHANGED,
     FSM_TRANSITION_SUCCESS_TRANSITIONED_FROM_STATE_TO_STATE,
+    PROTOCOL_ADAPTER_MANAGER_PROTOCOL_ADAPTER_DELETED,
+    PROTOCOL_ADAPTER_MANAGER_PROTOCOL_ADAPTER_NOT_FOUND,
     ;
 
     private static final @NotNull String RESOURCE_NAME_PREFIX = "templates/protocol-adapter-messages-";

hivemq-edge/src/main/java/com/hivemq/protocols/fsm/ProtocolAdapterConnectionState.java

@@ -42,4 +42,36 @@ public enum ProtocolAdapterConnectionState {
             final @NotNull Object context) {
         return transitionFunction.apply(context);
     }
+
+    public boolean isClosed() {
+        return this == Closed;
+    }
+
+    public boolean isClosing() {
+        return this == Closing;
+    }
+
+    public boolean isConnected() {
+        return this == Connected;
+    }
+
+    public boolean isConnecting() {
+        return this == Connecting;
+    }
+
+    public boolean isDisconnecting() {
+        return this == Disconnecting;
+    }
+
+    public boolean isDisconnected() {
+        return this == Disconnected;
+    }
+
+    public boolean isError() {
+        return this == Error;
+    }
+
+    public boolean isErrorClosing() {
+        return this == ErrorClosing;
+    }
 }

hivemq-edge/src/main/java/com/hivemq/protocols/fsm/ProtocolAdapterManager2.java

@@ -16,7 +16,7 @@
 
 package com.hivemq.protocols.fsm;
 
-public enum ProtocolAdapterOperatorState {
+public enum ProtocolAdapterManagerState {
     Idle,
     Running,
     ;