some enhance.

karsonto · Mar 21, 2024 · 1f8cf13 · 1f8cf13
1 parent d0b3678
commit 1f8cf13
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
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
@@ -76,7 +76,7 @@ public class EventMeshMQTTServer extends AbstractRemotingServer {
     private final Acl acl;
 
 
-    protected final transient Map<MqttMessageType, MqttProcessor> processorTable =
+    protected final Map<MqttMessageType, MqttProcessor> processorTable =
         new ConcurrentHashMap<>(64);
 
     private final transient AtomicBoolean started = new AtomicBoolean(false);

diff --git a/...main/java/org/apache/eventmesh/runtime/core/protocol/mqtt/processor/PublishProcessor.java b/...main/java/org/apache/eventmesh/runtime/core/protocol/mqtt/processor/PublishProcessor.java
@@ -51,7 +51,6 @@ public PublishProcessor(EventMeshMQTTServer eventMeshMQTTServer, Executor execut
 
     @Override
     public void process(ChannelHandlerContext ctx, MqttMessage mqttMessage) throws MqttException {
-        //
         clientManager.getOrRegisterClient(ctx, mqttMessage);
         MqttPublishMessage mqttPublishMessage = (MqttPublishMessage) mqttMessage;
         MqttFixedHeader mqttFixedHeaderInfo = mqttPublishMessage.fixedHeader();