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 <[email protected]>
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);