Fix logging lack param

Pil0tXia · Pil0tXia · commit 56b3d16d8eed · 2024-01-06T15:33:19.000+08:00
diff --git a/.gitignore b/.gitignore
@@ -23,7 +23,6 @@ classes
 package-lock.json
 node_modules
 .run
-*.log
 
 h2/db.mv.db
 
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ThreadPoolHelper.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ThreadPoolHelper.java
@@ -34,7 +34,7 @@ public static void printState(ThreadPoolExecutor threadPool) {
         log.info("The ThreadPool's state==================");
         log.info("Shutdown | Terminating | Terminated: {} | {} | {}", threadPool.isShutdown(), threadPool.isTerminating(), threadPool.isTerminated());
         log.info("Active Threads: " + threadPool.getActiveCount());
-        log.info("Completed Tasks / Tasks: {} / {}" + threadPool.getCompletedTaskCount(), threadPool.getTaskCount());
+        log.info("Completed Tasks / Tasks: {} / {}", threadPool.getCompletedTaskCount(), threadPool.getTaskCount());
         log.info("Queue Size: " + threadPool.getQueue().size());
         log.info("Core Pool Size: " + threadPool.getCorePoolSize());
         log.info("Maximum Pool Size: " + threadPool.getMaximumPoolSize());
diff --git a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/RequestContext.java b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/RequestContext.java
@@ -76,7 +76,7 @@ public void finish(Package msg) {
 
     public static RequestContext context(Object key, Package request, CountDownLatch latch) throws Exception {
         RequestContext c = new RequestContext(key, request, latch);
-        log.info("_RequestContext|create|key=", key);
+        log.info("_RequestContext|create|key={}", key);
         return c;
     }
 
diff --git a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/demo/SyncPubClient.java b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/demo/SyncPubClient.java
@@ -38,7 +38,7 @@ public static void main(String[] args) throws Exception {
                 Package rr = pubClient.rr(MessageUtils.rrMesssage("TEST-TOPIC-TCP-SYNC", i), 3000);
                 if (rr.getBody() instanceof EventMeshMessage) {
                     String body = ((EventMeshMessage) rr.getBody()).getBody();
-                    log.info("rrMessage: ", body, "             ", "rr-reply-------------------------------------------------{}", rr);
+                    log.info("rrMessage: " + body + "             " + "rr-reply-------------------------------------------------" + rr);
                 }
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ public void finish(Package msg) {`
`76`	`76`
`77`	`77`	`public static RequestContext context(Object key, Package request, CountDownLatch latch) throws Exception {`
`78`	`78`	`RequestContext c = new RequestContext(key, request, latch);`
`79`		`- log.info("_RequestContext\|create\|key=", key);`
	`79`	`+ log.info("_RequestContext\|create\|key={}", key);`
`80`	`80`	`return c;`
`81`	`81`	`}`
`82`	`82`
Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ public static void main(String[] args) throws Exception {`
`38`	`38`	`Package rr = pubClient.rr(MessageUtils.rrMesssage("TEST-TOPIC-TCP-SYNC", i), 3000);`
`39`	`39`	`if (rr.getBody() instanceof EventMeshMessage) {`
`40`	`40`	`String body = ((EventMeshMessage) rr.getBody()).getBody();`
`41`		`- log.info("rrMessage: ", body, " ", "rr-reply-------------------------------------------------{}", rr);`
	`41`	`+ log.info("rrMessage: " + body + " " + "rr-reply-------------------------------------------------" + rr);`
`42`	`42`	`}`
`43`	`43`	`}`
`44`	`44`	`}`