You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/04/20 05:42:08 UTC
[rocketmq] branch develop updated: [ISSUE #4165] add new line in sendMsgStatus (#4166)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 580b76d3d [ISSUE #4165] add new line in sendMsgStatus (#4166)
580b76d3d is described below
commit 580b76d3ded98fa906dec56f3bfcf79c3202a263
Author: yuz10 <84...@qq.com>
AuthorDate: Wed Apr 20 13:42:00 2022 +0800
[ISSUE #4165] add new line in sendMsgStatus (#4166)
* add new line in sendMsgStatus
* keep format consistent
---
.../org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java
index 69d3b24ca..f6366d5a2 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java
@@ -85,7 +85,7 @@ public class SendMsgStatusCommand implements SubCommand {
for (int i = 0; i < count; i++) {
long begin = System.currentTimeMillis();
SendResult result = producer.send(buildMessage(brokerName, messageSize));
- System.out.printf("rt:" + (System.currentTimeMillis() - begin) + "ms, SendResult=%s", result);
+ System.out.printf("rt=%sms, SendResult=%s%n", System.currentTimeMillis() - begin, result);
}
} catch (Exception e) {
throw new SubCommandException(this.getClass().getSimpleName() + " command failed", e);