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/12/03 08:41:38 UTC
[incubator-eventmesh] branch master updated: fix issue2382
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 09e53a998 fix issue2382
new 6fd54f19b Merge pull request #2429 from jonyangx/issue2382
09e53a998 is described below
commit 09e53a998841af4adf4610e96c822cd95c3f4d5c
Author: jonyangx <ya...@gmail.com>
AuthorDate: Sat Dec 3 14:36:09 2022 +0800
fix issue2382
---
.../apache/eventmesh/runtime/util/EventMeshUtil.java | 17 +++++++++--------
1 file changed, 9 insertions(+), 8 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/EventMeshUtil.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/EventMeshUtil.java
index 3e8856588..b13164304 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/EventMeshUtil.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/EventMeshUtil.java
@@ -59,9 +59,9 @@ import com.fasterxml.jackson.databind.SerializationFeature;
public class EventMeshUtil {
- private static final Logger logger = LoggerFactory.getLogger(EventMeshUtil.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger(EventMeshUtil.class);
- private static final Logger tcpLogger = LoggerFactory.getLogger("tcpMonitor");
+ private static final Logger TCPLOGGER = LoggerFactory.getLogger("tcpMonitor");
public static String buildPushMsgSeqNo() {
return StringUtils.rightPad(String.valueOf(System.currentTimeMillis()), 6) + RandomStringUtils.generateNum(4);
@@ -105,9 +105,10 @@ public class EventMeshUtil {
level = (level == 0) ? eles.length : level;
StringBuilder sb = new StringBuilder();
sb.append(e.getMessage()).append(System.lineSeparator());
+
int innerLevel = 0;
for (StackTraceElement ele : eles) {
- sb.append(ele.toString()).append(System.lineSeparator());
+ sb.append(ele).append(System.lineSeparator());
if (++innerLevel >= level) {
break;
}
@@ -165,7 +166,7 @@ public class EventMeshUtil {
public static String getLocalAddr() {
//priority of networkInterface when generating client ip
String priority = System.getProperty("networkInterface.priority", "bond1<eth1<eth0");
- logger.debug("networkInterface.priority: {}", priority);
+ LOGGER.debug("networkInterface.priority: {}", priority);
ArrayList<String> preferList = new ArrayList<String>();
for (String eth : priority.split("<")) {
preferList.add(eth);
@@ -192,11 +193,11 @@ public class EventMeshUtil {
ArrayList<String> ipv6Result = new ArrayList<String>();
if (preferNetworkInterface != null) {
- logger.debug("use preferNetworkInterface:{}", preferNetworkInterface);
+ LOGGER.debug("use preferNetworkInterface:{}", preferNetworkInterface);
final Enumeration<InetAddress> en = preferNetworkInterface.getInetAddresses();
getIpResult(ipv4Result, ipv6Result, en);
} else {
- logger.debug("no preferNetworkInterface");
+ LOGGER.debug("no preferNetworkInterface");
Enumeration<NetworkInterface> enumeration = NetworkInterface.getNetworkInterfaces();
while (enumeration.hasMoreElements()) {
final NetworkInterface networkInterface = enumeration.nextElement();
@@ -266,7 +267,7 @@ public class EventMeshUtil {
}
public static void printState(ThreadPoolExecutor scheduledExecutorService) {
- tcpLogger.info("{} [{} {} {} {}]", ((EventMeshThreadFactoryImpl) scheduledExecutorService.getThreadFactory())
+ TCPLOGGER.info("{} [{} {} {} {}]", ((EventMeshThreadFactoryImpl) scheduledExecutorService.getThreadFactory())
.getThreadNamePrefix(), scheduledExecutorService.getQueue().size(), scheduledExecutorService
.getPoolSize(), scheduledExecutorService.getActiveCount(), scheduledExecutorService
.getCompletedTaskCount());
@@ -302,7 +303,7 @@ public class EventMeshUtil {
}
return eventMeshCloudEventWriter.getExtensionMap();
} catch (Throwable e) {
- logger.warn("getCloudEventExtensionMap fail", e);
+ LOGGER.warn("getCloudEventExtensionMap fail", e);
return null;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org