[ISSUE #4236] TCP reconnection failed

apache · Jul 21, 2023 · 3499497 · 3499497
2 parents 022c051 + 1ba925b
commit 3499497
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java b/...src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java
@@ -37,6 +37,7 @@
 import io.cloudevents.core.format.EventFormat;
 import io.cloudevents.core.provider.EventFormatProvider;
 import io.cloudevents.jackson.JsonFormat;
+import io.netty.channel.ChannelHandler.Sharable;
 import io.netty.channel.ChannelHandlerContext;
 
 import com.google.common.base.Preconditions;
@@ -138,6 +139,7 @@ public void close() {
         }
     }
 
+    @Sharable
     private class CloudEventTCPPubHandler extends AbstractEventMeshTCPPubHandler<CloudEvent> {
 
         public CloudEventTCPPubHandler(ConcurrentHashMap<Object, RequestContext> contexts) {

diff --git a/...src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java b/...src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java
@@ -44,6 +44,7 @@
 import io.cloudevents.core.format.EventFormat;
 import io.cloudevents.core.provider.EventFormatProvider;
 import io.cloudevents.jackson.JsonFormat;
+import io.netty.channel.ChannelHandler.Sharable;
 import io.netty.channel.ChannelHandlerContext;
 
 import com.google.common.base.Preconditions;
@@ -141,6 +142,7 @@ public void close() {
         }
     }
 
+    @Sharable
     private class CloudEventTCPSubHandler extends AbstractEventMeshTCPSubHandler<CloudEvent> {
 
         public CloudEventTCPSubHandler(