You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ti...@apache.org on 2021/06/10 06:19:41 UTC
[rocketmq] branch develop updated: #2990 Add message tracing switch
in sendMessage command of mqadmin
This is an automated email from the ASF dual-hosted git repository.
tigerlee 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 2fe6dc3 #2990 Add message tracing switch in sendMessage command of mqadmin
new 57c166b Merge pull request #2991 from yuz10/develop4
2fe6dc3 is described below
commit 2fe6dc3034f3d886227c0afbade7ad785e5f9edc
Author: yuz10 <84...@qq.com>
AuthorDate: Wed Jun 9 00:57:42 2021 +0800
#2990 Add message tracing switch in sendMessage command of mqadmin
---
.../tools/command/message/SendMessageCommand.java | 17 ++++++++++++-----
1 file changed, 12 insertions(+), 5 deletions(-)
diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java
index e4921c6..9550742 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java
@@ -68,14 +68,18 @@ public class SendMessageCommand implements SubCommand {
opt.setRequired(false);
options.addOption(opt);
+ opt = new Option("m", "msgTraceEnable", true, "Message Trace Enable, Default: false");
+ opt.setRequired(false);
+ options.addOption(opt);
+
return options;
}
- private DefaultMQProducer createProducer(RPCHook rpcHook) {
+ private DefaultMQProducer createProducer(RPCHook rpcHook, boolean msgTraceEnable) {
if (this.producer != null) {
return producer;
} else {
- producer = new DefaultMQProducer(rpcHook);
+ producer = new DefaultMQProducer(null, rpcHook, msgTraceEnable, null);
producer.setProducerGroup(Long.toString(System.currentTimeMillis()));
return producer;
}
@@ -112,8 +116,11 @@ public class SendMessageCommand implements SubCommand {
} catch (Exception e) {
throw new RuntimeException(this.getClass().getSimpleName() + " command failed", e);
}
-
- DefaultMQProducer producer = this.createProducer(rpcHook);
+ boolean msgTraceEnable = false;
+ if (commandLine.hasOption('m')) {
+ msgTraceEnable = Boolean.parseBoolean(commandLine.getOptionValue('m').trim());
+ }
+ DefaultMQProducer producer = this.createProducer(rpcHook, msgTraceEnable);
SendResult result;
try {
producer.start();
@@ -153,4 +160,4 @@ public class SendMessageCommand implements SubCommand {
);
}
}
-}
\ No newline at end of file
+}