You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/10/22 23:32:12 UTC
[incubator-eventmesh] branch master updated: Update GoodbyeTask.java
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new a3c195cd Update GoodbyeTask.java
new 253281bd Merge pull request #1758 from rrpari/patch-2
a3c195cd is described below
commit a3c195cd2621e5d5f4a4a000eb091a441f269775
Author: Pari Rajarathinam <74...@users.noreply.github.com>
AuthorDate: Sat Oct 22 22:23:23 2022 +0530
Update GoodbyeTask.java
---
.../eventmesh/runtime/core/protocol/tcp/client/task/GoodbyeTask.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/GoodbyeTask.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/GoodbyeTask.java
index 0eeabf2d..49f5f605 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/GoodbyeTask.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/GoodbyeTask.java
@@ -29,6 +29,8 @@ import org.apache.eventmesh.runtime.util.Utils;
import io.netty.channel.ChannelHandlerContext;
+import java.util.Arrays;
+
public class GoodbyeTask extends AbstractTask {
public GoodbyeTask(Package pkg, ChannelHandlerContext ctx, long startTime, EventMeshTCPServer eventMeshTCPServer) {
@@ -49,7 +51,7 @@ public class GoodbyeTask extends AbstractTask {
}
} catch (Exception e) {
logger.error("GoodbyeTask failed|user={}|errMsg={}", session.getClient(), e);
- msg.setHeader(new Header(CLIENT_GOODBYE_RESPONSE, OPStatus.FAIL.getCode(), e.getStackTrace().toString(), pkg
+ msg.setHeader(new Header(CLIENT_GOODBYE_RESPONSE, OPStatus.FAIL.getCode(), Arrays.toString(e.getStackTrace()), pkg
.getHeader().getSeq()));
} finally {
this.eventMeshTCPServer.getScheduler().submit(new Runnable() {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org