[ISSUE #783] test check style

apache · Feb 24, 2022 · e72a326 · e72a326
1 parent 73b237f
commit e72a326
Show file tree

Hide file tree

Showing 83 changed files with 1,254 additions and 1,250 deletions.
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/acl/Acl.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/acl/Acl.java
@@ -22,9 +22,12 @@
 import org.apache.eventmesh.api.exception.AclException;
 import org.apache.eventmesh.common.protocol.tcp.UserAgent;
 import org.apache.eventmesh.spi.EventMeshExtensionFactory;
+
 import org.apache.commons.lang3.StringUtils;
+
 import java.util.Properties;
 import java.util.ServiceLoader;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/...c/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByIpPortHandler.java b/...c/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByIpPortHandler.java
@@ -61,47 +61,47 @@ public void handle(HttpExchange httpExchange) throws IOException {
             String destEventMeshPort = queryStringInfo.get(EventMeshConstants.MANAGE_DEST_PORT);
 
             if (StringUtils.isBlank(ip) || !StringUtils.isNumeric(port)
-                    || StringUtils.isBlank(destEventMeshIp) || StringUtils.isBlank(destEventMeshPort)
-                    || !StringUtils.isNumeric(destEventMeshPort)) {
+                || StringUtils.isBlank(destEventMeshIp) || StringUtils.isBlank(destEventMeshPort)
+                || !StringUtils.isNumeric(destEventMeshPort)) {
                 httpExchange.sendResponseHeaders(200, 0);
                 result = "params illegal!";
                 out.write(result.getBytes());
                 return;
             }
             logger.info("redirectClientByIpPort in admin,ip:{},port:{},destIp:{},destPort:{}====================", ip,
-                    port, destEventMeshIp, destEventMeshPort);
+                port, destEventMeshIp, destEventMeshPort);
             ClientSessionGroupMapping clientSessionGroupMapping = eventMeshTCPServer.getClientSessionGroupMapping();
             ConcurrentHashMap<InetSocketAddress, Session> sessionMap = clientSessionGroupMapping.getSessionMap();
             String redirectResult = "";
             try {
                 if (!sessionMap.isEmpty()) {
                     for (Session session : sessionMap.values()) {
                         if (session.getClient().getHost().equals(ip) && String.valueOf(
-                                session.getClient().getPort()).equals(port)) {
+                            session.getClient().getPort()).equals(port)) {
                             redirectResult += "|";
                             redirectResult += EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer,
-                                    destEventMeshIp, Integer.parseInt(destEventMeshPort),
-                                    session, clientSessionGroupMapping);
+                                destEventMeshIp, Integer.parseInt(destEventMeshPort),
+                                session, clientSessionGroupMapping);
                         }
                     }
                 }
             } catch (Exception e) {
                 logger.error("clientManage|redirectClientByIpPort|fail|ip={}|port={}|destEventMeshIp"
-                        +
-                        "={}|destEventMeshPort={},errMsg={}", ip, port, destEventMeshIp, destEventMeshPort, e);
+                    +
+                    "={}|destEventMeshPort={},errMsg={}", ip, port, destEventMeshIp, destEventMeshPort, e);
                 result = String.format("redirectClientByIpPort fail! sessionMap size {%d}, {clientIp=%s clientPort=%s "
-                                +
-                                "destEventMeshIp=%s destEventMeshPort=%s}, result {%s}, errorMsg : %s",
-                        sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort, redirectResult, e
-                                .getMessage());
+                        +
+                        "destEventMeshIp=%s destEventMeshPort=%s}, result {%s}, errorMsg : %s",
+                    sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort, redirectResult, e
+                        .getMessage());
                 httpExchange.sendResponseHeaders(200, 0);
                 out.write(result.getBytes());
                 return;
             }
             result = String.format("redirectClientByIpPort success! sessionMap size {%d}, {ip=%s port=%s "
-                            +
-                            "destEventMeshIp=%s destEventMeshPort=%s}, result {%s} ",
-                    sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort, redirectResult);
+                    +
+                    "destEventMeshIp=%s destEventMeshPort=%s}, result {%s} ",
+                sessionMap.size(), ip, port, destEventMeshIp, destEventMeshPort, redirectResult);
             httpExchange.sendResponseHeaders(200, 0);
             out.write(result.getBytes());
         } catch (Exception e) {

diff --git a/...src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByPathHandler.java b/...src/main/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByPathHandler.java
@@ -63,15 +63,15 @@ public void handle(HttpExchange httpExchange) throws IOException {
             String destEventMeshPort = queryStringInfo.get(EventMeshConstants.MANAGE_DEST_PORT);
 
             if (StringUtils.isBlank(path) || StringUtils.isBlank(destEventMeshIp)
-                    || StringUtils.isBlank(destEventMeshPort)
-                    || !StringUtils.isNumeric(destEventMeshPort)) {
+                || StringUtils.isBlank(destEventMeshPort)
+                || !StringUtils.isNumeric(destEventMeshPort)) {
                 httpExchange.sendResponseHeaders(200, 0);
                 result = "params illegal!";
                 out.write(result.getBytes());
                 return;
             }
             logger.info("redirectClientByPath in admin,path:{},destIp:{},destPort:{}====================", path,
-                    destEventMeshIp, destEventMeshPort);
+                destEventMeshIp, destEventMeshPort);
             ClientSessionGroupMapping clientSessionGroupMapping = eventMeshTCPServer.getClientSessionGroupMapping();
             ConcurrentHashMap<InetSocketAddress, Session> sessionMap = clientSessionGroupMapping.getSessionMap();
             String redirectResult = "";
@@ -81,28 +81,28 @@ public void handle(HttpExchange httpExchange) throws IOException {
                         if (session.getClient().getPath().contains(path)) {
                             redirectResult += "|";
                             redirectResult += EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer,
-                                    destEventMeshIp, Integer.parseInt(destEventMeshPort),
-                                    session, clientSessionGroupMapping);
+                                destEventMeshIp, Integer.parseInt(destEventMeshPort),
+                                session, clientSessionGroupMapping);
                         }
                     }
                 }
             } catch (Exception e) {
                 logger.error("clientManage|redirectClientByPath|fail|path={}|destEventMeshIp"
-                        +
-                        "={}|destEventMeshPort={},errMsg={}", path, destEventMeshIp, destEventMeshPort, e);
+                    +
+                    "={}|destEventMeshPort={},errMsg={}", path, destEventMeshIp, destEventMeshPort, e);
                 result = String.format("redirectClientByPath fail! sessionMap size {%d}, {path=%s "
-                                +
-                                "destEventMeshIp=%s destEventMeshPort=%s}, result {%s}, errorMsg : %s",
-                        sessionMap.size(), path, destEventMeshIp, destEventMeshPort, redirectResult, e
-                                .getMessage());
+                        +
+                        "destEventMeshIp=%s destEventMeshPort=%s}, result {%s}, errorMsg : %s",
+                    sessionMap.size(), path, destEventMeshIp, destEventMeshPort, redirectResult, e
+                        .getMessage());
                 httpExchange.sendResponseHeaders(200, 0);
                 out.write(result.getBytes());
                 return;
             }
             result = String.format("redirectClientByPath success! sessionMap size {%d}, {path=%s "
-                            +
-                            "destEventMeshIp=%s destEventMeshPort=%s}, result {%s} ",
-                    sessionMap.size(), path, destEventMeshIp, destEventMeshPort, redirectResult);
+                    +
+                    "destEventMeshIp=%s destEventMeshPort=%s}, result {%s} ",
+                sessionMap.size(), path, destEventMeshIp, destEventMeshPort, redirectResult);
             httpExchange.sendResponseHeaders(200, 0);
             out.write(result.getBytes());
         } catch (Exception e) {

diff --git a/...ain/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientBySubSystemHandler.java b/...ain/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientBySubSystemHandler.java
@@ -63,15 +63,15 @@ public void handle(HttpExchange httpExchange) throws IOException {
             String destEventMeshPort = queryStringInfo.get(EventMeshConstants.MANAGE_DEST_PORT);
 
             if (!StringUtils.isNumeric(subSystem)
-                    || StringUtils.isBlank(destEventMeshIp) || StringUtils.isBlank(destEventMeshPort)
-                    || !StringUtils.isNumeric(destEventMeshPort)) {
+                || StringUtils.isBlank(destEventMeshIp) || StringUtils.isBlank(destEventMeshPort)
+                || !StringUtils.isNumeric(destEventMeshPort)) {
                 httpExchange.sendResponseHeaders(200, 0);
                 result = "params illegal!";
                 out.write(result.getBytes());
                 return;
             }
             logger.info("redirectClientBySubSystem in admin,subsys:{},destIp:{},destPort:{}====================",
-                    subSystem, destEventMeshIp, destEventMeshPort);
+                subSystem, destEventMeshIp, destEventMeshPort);
             ClientSessionGroupMapping clientSessionGroupMapping = eventMeshTCPServer.getClientSessionGroupMapping();
             ConcurrentHashMap<InetSocketAddress, Session> sessionMap = clientSessionGroupMapping.getSessionMap();
             String redirectResult = "";
@@ -81,28 +81,28 @@ public void handle(HttpExchange httpExchange) throws IOException {
                         if (session.getClient().getSubsystem().equals(subSystem)) {
                             redirectResult += "|";
                             redirectResult += EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer,
-                                    destEventMeshIp, Integer.parseInt(destEventMeshPort),
-                                    session, clientSessionGroupMapping);
+                                destEventMeshIp, Integer.parseInt(destEventMeshPort),
+                                session, clientSessionGroupMapping);
                         }
                     }
                 }
             } catch (Exception e) {
                 logger.error("clientManage|redirectClientBySubSystem|fail|subSystem={}|destEventMeshIp"
-                        +
-                        "={}|destEventMeshPort={},errMsg={}", subSystem, destEventMeshIp, destEventMeshPort, e);
+                    +
+                    "={}|destEventMeshPort={},errMsg={}", subSystem, destEventMeshIp, destEventMeshPort, e);
                 result = String.format("redirectClientBySubSystem fail! sessionMap size {%d}, {subSystem=%s "
-                                +
-                                "destEventMeshIp=%s destEventMeshPort=%s}, result {%s}, errorMsg : %s",
-                        sessionMap.size(), subSystem, destEventMeshIp, destEventMeshPort, redirectResult, e
-                                .getMessage());
+                        +
+                        "destEventMeshIp=%s destEventMeshPort=%s}, result {%s}, errorMsg : %s",
+                    sessionMap.size(), subSystem, destEventMeshIp, destEventMeshPort, redirectResult, e
+                        .getMessage());
                 httpExchange.sendResponseHeaders(200, 0);
                 out.write(result.getBytes());
                 return;
             }
             result = String.format("redirectClientBySubSystem success! sessionMap size {%d}, {subSystem=%s "
-                            +
-                            "destEventMeshIp=%s destEventMeshPort=%s}, result {%s} ",
-                    sessionMap.size(), subSystem, destEventMeshIp, destEventMeshPort, redirectResult);
+                    +
+                    "destEventMeshIp=%s destEventMeshPort=%s}, result {%s} ",
+                sessionMap.size(), subSystem, destEventMeshIp, destEventMeshPort, redirectResult);
             httpExchange.sendResponseHeaders(200, 0);
             out.write(result.getBytes());
         } catch (Exception e) {

diff --git a/...time/src/main/java/org/apache/eventmesh/runtime/admin/handler/RejectAllClientHandler.java b/...time/src/main/java/org/apache/eventmesh/runtime/admin/handler/RejectAllClientHandler.java
@@ -66,7 +66,7 @@ public void handle(HttpExchange httpExchange) throws IOException {
                 if (!sessionMap.isEmpty()) {
                     for (Map.Entry<InetSocketAddress, Session> entry : sessionMap.entrySet()) {
                         InetSocketAddress addr = EventMeshTcp2Client.serverGoodby2Client(
-                                eventMeshTCPServer, entry.getValue(), clientSessionGroupMapping);
+                            eventMeshTCPServer, entry.getValue(), clientSessionGroupMapping);
                         if (addr != null) {
                             successRemoteAddrs.add(addr);
                         }
@@ -75,13 +75,13 @@ public void handle(HttpExchange httpExchange) throws IOException {
             } catch (Exception e) {
                 logger.error("clientManage|rejectAllClient|fail", e);
                 result = String.format("rejectAllClient fail! sessionMap size {%d}, had reject {%s}, errorMsg : %s",
-                        sessionMap.size(), NetUtils.addressToString(successRemoteAddrs), e.getMessage());
+                    sessionMap.size(), NetUtils.addressToString(successRemoteAddrs), e.getMessage());
                 httpExchange.sendResponseHeaders(200, 0);
                 out.write(result.getBytes());
                 return;
             }
             result = String.format("rejectAllClient success! sessionMap size {%d}, had reject {%s}", sessionMap.size(),
-                    NetUtils.addressToString(successRemoteAddrs));
+                NetUtils.addressToString(successRemoteAddrs));
             httpExchange.sendResponseHeaders(200, 0);
             out.write(result.getBytes());
         } catch (Exception e) {

diff --git a/...src/main/java/org/apache/eventmesh/runtime/admin/handler/RejectClientByIpPortHandler.java b/...src/main/java/org/apache/eventmesh/runtime/admin/handler/RejectClientByIpPortHandler.java
@@ -75,7 +75,7 @@ public void handle(HttpExchange httpExchange) throws IOException {
                     for (Map.Entry<InetSocketAddress, Session> entry : sessionMap.entrySet()) {
                         if (entry.getKey().getHostString().equals(ip) && String.valueOf(entry.getKey().getPort()).equals(port)) {
                             InetSocketAddress addr = EventMeshTcp2Client.serverGoodby2Client(eventMeshTCPServer,
-                                    entry.getValue(), clientSessionGroupMapping);
+                                entry.getValue(), clientSessionGroupMapping);
                             if (addr != null) {
                                 successRemoteAddrs.add(addr);
                             }
@@ -85,14 +85,14 @@ public void handle(HttpExchange httpExchange) throws IOException {
             } catch (Exception e) {
                 logger.error("clientManage|rejectClientByIpPort|fail|ip={}|port={},errMsg={}", ip, port, e);
                 result = String.format("rejectClientByIpPort fail! {ip=%s port=%s}, had reject {%s}, errorMsg : %s", ip,
-                        port, NetUtils.addressToString(successRemoteAddrs), e.getMessage());
+                    port, NetUtils.addressToString(successRemoteAddrs), e.getMessage());
                 httpExchange.sendResponseHeaders(200, 0);
                 out.write(result.getBytes());
                 return;
             }
 
             result = String.format("rejectClientByIpPort success! {ip=%s port=%s}, had reject {%s}", ip, port,
-                    NetUtils.addressToString(successRemoteAddrs));
+                NetUtils.addressToString(successRemoteAddrs));
             httpExchange.sendResponseHeaders(200, 0);
             out.write(result.getBytes());
         } catch (Exception e) {

diff --git a/.../main/java/org/apache/eventmesh/runtime/admin/handler/RejectClientBySubSystemHandler.java b/.../main/java/org/apache/eventmesh/runtime/admin/handler/RejectClientBySubSystemHandler.java
@@ -101,15 +101,15 @@ public void handle(HttpExchange httpExchange) throws IOException {
             } catch (Exception e) {
                 logger.error("clientManage|rejectClientBySubSystem|fail|subSystemId={},errMsg={}", subSystem, e);
                 result = String.format("rejectClientBySubSystem fail! sessionMap size {%d}, had reject {%d} , {"
-                        +
-                        "subSystemId=%s}, errorMsg : %s", sessionMap.size(), printClients(successRemoteAddrs), subSystem, e.getMessage());
+                    +
+                    "subSystemId=%s}, errorMsg : %s", sessionMap.size(), printClients(successRemoteAddrs), subSystem, e.getMessage());
                 httpExchange.sendResponseHeaders(200, 0);
                 out.write(result.getBytes());
                 return;
             }
             result = String.format("rejectClientBySubSystem success! sessionMap size {%d}, had reject {%s} , {"
-                    +
-                    "subSystemId=%s}", sessionMap.size(), printClients(successRemoteAddrs), subSystem);
+                +
+                "subSystemId=%s}", sessionMap.size(), printClients(successRemoteAddrs), subSystem);
             httpExchange.sendResponseHeaders(200, 0);
             out.write(result.getBytes());
         } catch (Exception e) {

diff --git a/...e/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowClientBySystemHandler.java b/...e/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowClientBySystemHandler.java
@@ -70,7 +70,7 @@ public void handle(HttpExchange httpExchange) throws IOException {
                     if (session.getClient().getSubsystem().equals(subSystem)) {
                         UserAgent userAgent = session.getClient();
                         result += String.format("pid=%s | ip=%s | port=%s | path=%s | purpose=%s", userAgent.getPid(), userAgent
-                                .getHost(), userAgent.getPort(), userAgent.getPath(), userAgent.getPurpose()) + newLine;
+                            .getHost(), userAgent.getPort(), userAgent.getPath(), userAgent.getPurpose()) + newLine;
                     }
                 }
             }

diff --git a/...h-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowClientHandler.java b/...h-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowClientHandler.java
@@ -71,8 +71,8 @@ public void handle(HttpExchange httpExchange) throws IOException {
 
                 for (Map.Entry<String, AtomicInteger> entry : statMap.entrySet()) {
                     result += String.format("System=%s | ClientNum=%d", entry.getKey(), entry.getValue().intValue())
-                            +
-                            newLine;
+                        +
+                        newLine;
                 }
             }
 

diff --git a/.../main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java b/.../main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java
@@ -71,7 +71,7 @@ public void handle(HttpExchange httpExchange) throws IOException {
                         for (Session session : listenSessionSet) {
                             UserAgent userAgent = session.getClient();
                             result += String.format("pid=%s | ip=%s | port=%s | path=%s | version=%s", userAgent.getPid(), userAgent
-                                    .getHost(), userAgent.getPort(), userAgent.getPath(), userAgent.getVersion()) + newLine;
+                                .getHost(), userAgent.getPort(), userAgent.getPath(), userAgent.getVersion()) + newLine;
                         }
                     }
                 }