diff --git a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java index 935cd55c38..9be280f563 100644 --- a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java +++ b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java @@ -96,7 +96,6 @@ public void asyncRR(CloudEvent event, AsyncRRCallback callback, long timeout) th super.send(msg); this.callbackConcurrentHashMap.put((String) RequestContext.key(msg), callback); } catch (Exception ex) { - // should trigger callback? throw new EventMeshException("asyncRR error", ex); } }