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 5833cff4a [ISSUE #3157] Using placeholder
new b6a19fc17 Merge pull request #3214 from Bannirui/fix-3157
5833cff4a is described below
commit 5833cff4a092f5881e3e5142cbb22217117faf13
Author: dingrui <[email protected]>
AuthorDate: Mon Feb 20 14:12:05 2023 +0800
[ISSUE #3157] Using placeholder
---
.../test/java/org/apache/eventmesh/runtime/demo/SyncSubClient.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/demo/SyncSubClient.java
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/demo/SyncSubClient.java
index 010555a10..8ff8247c7 100644
---
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/demo/SyncSubClient.java
+++
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/demo/SyncSubClient.java
@@ -36,7 +36,7 @@ public class SyncSubClient {
public static void main(String[] args) throws Exception {
try (SubClientImpl client =
- new SubClientImpl("localhost", 10000,
MessageUtils.generateSubServer())) {
+ new SubClientImpl("localhost", 10000,
MessageUtils.generateSubServer())) {
client.init();
client.heartbeat();
client.justSubscribe(ClientConstants.SYNC_TOPIC,
SubscriptionMode.CLUSTERING, SubscriptionType.SYNC);
@@ -45,7 +45,7 @@ public class SyncSubClient {
public void handle(Package msg, ChannelHandlerContext ctx) {
if (msg.getHeader().getCommand() ==
Command.REQUEST_TO_CLIENT) {
if ((log.isInfoEnabled())) {
- log.info("receive message
-------------------------------" + msg);
+ log.info("receive message: {}", msg);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
