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 70c6c7338 [Issue: #2974]: logging concat update
new ae98213fa Merge pull request #3486 from kvaithin/fix-2974-log-update
70c6c7338 is described below
commit 70c6c7338ccf621d443d0badaa96e6ff470bb4bb
Author: Karthik Vaithin <[email protected]>
AuthorDate: Sun Mar 19 00:20:38 2023 +0000
[Issue: #2974]: logging concat update
---
.../eventmesh/client/grpc/producer/CloudEventProducer.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
index aaa8ab73a..6d2793772 100644
---
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
+++
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
@@ -74,7 +74,7 @@ public class CloudEventProducer {
try {
final Response response =
publisherClient.batchPublish(enhancedMessage);
if (log.isInfoEnabled()) {
- log.info("Received response " + response.toString());
+ log.info("Received response {}", response);
}
return response;
} catch (Exception e) {
@@ -87,7 +87,7 @@ public class CloudEventProducer {
public Response publish(final CloudEvent cloudEvent) {
if (log.isInfoEnabled()) {
- log.info("Publish message " + cloudEvent.toString());
+ log.info("Publish message {}", cloudEvent);
}
final CloudEvent enhanceEvent = enhanceCloudEvent(cloudEvent, null);
@@ -96,7 +96,7 @@ public class CloudEventProducer {
try {
final Response response = publisherClient.publish(enhancedMessage);
if (log.isInfoEnabled()) {
- log.info("Received response " + response.toString());
+ log.info("Received response {}", response);
}
return response;
} catch (Exception e) {
@@ -109,7 +109,7 @@ public class CloudEventProducer {
public CloudEvent requestReply(final CloudEvent cloudEvent, final int
timeout) {
if (log.isInfoEnabled()) {
- log.info("RequestReply message " + cloudEvent.toString());
+ log.info("RequestReply message {}", cloudEvent);
}
final CloudEvent enhanceEvent = enhanceCloudEvent(cloudEvent,
String.valueOf(timeout));
@@ -118,7 +118,7 @@ public class CloudEventProducer {
try {
final SimpleMessage reply =
publisherClient.requestReply(enhancedMessage);
if (log.isInfoEnabled()) {
- log.info("Received reply message:{}", reply.toString());
+ log.info("Received reply message:{}", reply);
}
final Object msg = EventMeshClientUtil.buildMessage(reply,
PROTOCOL_TYPE);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
