This is an automated email from the ASF dual-hosted git repository.
pandaapo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 56713fbaa fix() : Resolve ambiguity in method names in
AbstractTCPServer (#4571)
56713fbaa is described below
commit 56713fbaa2116c44e580b4b09b8a52f0af91c04c
Author: hhuang <[email protected]>
AuthorDate: Mon Nov 20 17:45:29 2023 +0800
fix() : Resolve ambiguity in method names in AbstractTCPServer (#4571)
---
.../java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java
index 708f0000e..81927d6f4 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java
@@ -255,7 +255,7 @@ public class AbstractTCPServer extends
AbstractRemotingServer {
if (Command.HELLO_REQUEST == cmd || Command.RECOMMEND_REQUEST
== cmd) {
LogUtils.info(messageLogger,
"pkg|c2eventMesh|cmd={}|pkg={}", cmd, pkg);
- processHttpCommandRequest(pkg, ctx, startTime, cmd);
+ processTcpCommandRequest(pkg, ctx, startTime, cmd);
return;
}
@@ -272,7 +272,7 @@ public class AbstractTCPServer extends
AbstractRemotingServer {
"this eventMesh tcp session will be closed, may be
reboot or version change!");
}
- processHttpCommandRequest(pkg, ctx, startTime, cmd);
+ processTcpCommandRequest(pkg, ctx, startTime, cmd);
} catch (Exception e) {
log.error("exception occurred while pkg|cmd={}|pkg={}", cmd,
pkg, e);
@@ -288,8 +288,8 @@ public class AbstractTCPServer extends
AbstractRemotingServer {
}
}
- private void processHttpCommandRequest(final Package pkg, final
ChannelHandlerContext ctx,
- final long startTime, final Command cmd) {
+ private void processTcpCommandRequest(final Package pkg, final
ChannelHandlerContext ctx,
+ final long startTime, final
Command cmd) {
Pair<TcpProcessor, ThreadPoolExecutor> pair =
tcpRequestProcessorTable.get(cmd);
pair.getObject2().submit(() -> {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
