You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/11/30 06:32:56 UTC
[incubator-eventmesh] branch master updated: Enhancement
This is an automated email from the ASF dual-hosted git repository.
mikexue 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 c1461bbc2 Enhancement
new 3c52544cb Merge pull request #2305 from weihubeats/wh_feature
c1461bbc2 is described below
commit c1461bbc271dab017c3d488349bd7135d9e57a9d
Author: weihu <we...@163.com>
AuthorDate: Tue Nov 29 14:33:20 2022 +0800
Enhancement
---
.../runtime/admin/handler/RedirectClientByPathHandler.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByPathHandler.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByPathHandler.java
index a843d6832..577692784 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByPathHandler.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByPathHandler.java
@@ -74,15 +74,15 @@ public class RedirectClientByPathHandler implements HttpHandler {
destEventMeshIp, destEventMeshPort);
ClientSessionGroupMapping clientSessionGroupMapping = eventMeshTCPServer.getClientSessionGroupMapping();
ConcurrentHashMap<InetSocketAddress, Session> sessionMap = clientSessionGroupMapping.getSessionMap();
- String redirectResult = "";
+ StringBuilder redirectResult = new StringBuilder();
try {
if (!sessionMap.isEmpty()) {
for (Session session : sessionMap.values()) {
if (session.getClient().getPath().contains(path)) {
- redirectResult += "|";
- redirectResult += EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer,
- destEventMeshIp, Integer.parseInt(destEventMeshPort),
- session, clientSessionGroupMapping);
+ redirectResult.append("|");
+ redirectResult.append(EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer,
+ destEventMeshIp, Integer.parseInt(destEventMeshPort),
+ session, clientSessionGroupMapping));
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org