You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by wa...@apache.org on 2022/12/06 06:55:48 UTC
[incubator-eventmesh] branch master updated: fix #2361
This is an automated email from the ASF dual-hosted git repository.
walterzywei 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 df3ba8ae8 fix #2361
new 46763c0dd Merge pull request #2479 from huyuanxin/fix2361
df3ba8ae8 is described below
commit df3ba8ae8cb088582425840b2b94f429c35f3975
Author: huyuanxin <hu...@outlook.com>
AuthorDate: Tue Dec 6 14:47:27 2022 +0800
fix #2361
#2361
---
.../runtime/core/protocol/tcp/client/task/MessageAckTask.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageAckTask.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageAckTask.java
index a01615bab..321766bc1 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageAckTask.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageAckTask.java
@@ -51,12 +51,12 @@ public class MessageAckTask extends AbstractTask {
downStreamMsgContext.ackMsg();
session.getPusher().getUnAckMsg().remove(seq);
} else {
- if (!cmd.equals(Command.RESPONSE_TO_CLIENT_ACK)) {
+ if (cmd != Command.RESPONSE_TO_CLIENT_ACK) {
logger.warn("MessageAckTask, seq:{}, downStreamMsgContext not in downStreamMap,client:{}",
- seq, session.getClient());
+ seq, session.getClient());
}
}
messageLogger.info("pkg|c2eventMesh|cmd={}|seq=[{}]|user={}|wait={}ms|cost={}ms", cmd, seq, session.getClient(),
- taskExecuteTime - startTime, System.currentTimeMillis() - startTime);
+ taskExecuteTime - startTime, System.currentTimeMillis() - startTime);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org