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 57e0b3990 [ISSUE #3156] Using placeholder
new 963912594 Merge pull request #3215 from Bannirui/fix-3156
57e0b3990 is described below
commit 57e0b399071ed384950a39bddd95cc3eb35a1eb7
Author: dingrui <[email protected]>
AuthorDate: Mon Feb 20 14:18:36 2023 +0800
[ISSUE #3156] Using placeholder
---
.../test/java/org/apache/eventmesh/runtime/demo/SyncPubClient.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
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
index 855738acb..b2e922d10 100644
---
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
@@ -30,7 +30,7 @@ public class SyncPubClient {
public static void main(String[] args) throws Exception {
try (PubClientImpl pubClient =
- new PubClientImpl("localhost", 10000,
UserAgentUtils.createUserAgent())) {
+ new PubClientImpl("localhost", 10000,
UserAgentUtils.createUserAgent())) {
pubClient.init();
pubClient.heartbeat();
@@ -39,8 +39,7 @@ public class SyncPubClient {
if (rr.getBody() instanceof EventMeshMessage) {
String body = ((EventMeshMessage) rr.getBody()).getBody();
if (log.isInfoEnabled()) {
- log.info("rrMessage: " + body + " "
- +
"rr-reply-------------------------------------------------" + rr);
+ log.info("rrMessage: {}, rr-reply: {}", body, rr);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
