From 44e61e9d55f0bf1cc79e92e2aad5b0881a954a5f Mon Sep 17 00:00:00 2001 From: karsonto Date: Thu, 28 Mar 2024 09:20:47 +0800 Subject: [PATCH] some enhance. --- .../org/apache/eventmesh/runtime/boot/EventMeshMQTTServer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshMQTTServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshMQTTServer.java index c9194bb860..cf603a1424 100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshMQTTServer.java +++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshMQTTServer.java @@ -79,7 +79,7 @@ public class EventMeshMQTTServer extends AbstractRemotingServer { protected final Map processorTable = new ConcurrentHashMap<>(64); - private final transient AtomicBoolean started = new AtomicBoolean(false); + private final AtomicBoolean started = new AtomicBoolean(false); public EventMeshMQTTServer(final EventMeshServer eventMeshServer, final EventMeshMQTTConfiguration eventMeshMQTTConfiguration) {