diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/SyncRequestInstance.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/SyncRequestInstance.java index 9077e574c1..b2d780e1be 100644 --- a/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/SyncRequestInstance.java +++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/SyncRequestInstance.java @@ -73,18 +73,18 @@ public static void main(String[] args) throws Exception { EventMeshMessage rsp = eventMeshHttpProducer.request(eventMeshMessage, 10000); if (logger.isDebugEnabled()) { - logger.debug("sendmsg: {}, return: {}, cost:{} ms", eventMeshMessage.getContent(), rsp.getContent(), + logger.debug("send msg: {}, return: {}, cost:{} ms", eventMeshMessage.getContent(), rsp.getContent(), System.currentTimeMillis() - startTime); } } catch (Exception e) { - logger.warn("send msg failed", e); + logger.warn("send msg failed, ", e); } Thread.sleep(30000); try (final EventMeshHttpProducer close = eventMeshHttpProducer) { // close producer } catch (Exception e1) { - logger.warn("producer shutdown exception", e1); + logger.warn("producer shutdown exception, ", e1); } } }