diff --git a/example/src/main/java/org/apache/rocketmq/example/broadcast/PushConsumer.java b/example/src/main/java/org/apache/rocketmq/example/broadcast/PushConsumer.java index f3f2cf634ccc2e2e36f460ea8ca95b393c48674f..fb1f9bbde7110fe0b9a500e771cf70a8fe4f0c95 100644 --- a/example/src/main/java/org/apache/rocketmq/example/broadcast/PushConsumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/broadcast/PushConsumer.java @@ -42,7 +42,7 @@ public class PushConsumer { @Override public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) { - System.out.printf(Thread.currentThread().getName() + " Receive New Messages: " + msgs + "%n"); + System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); diff --git a/example/src/main/java/org/apache/rocketmq/example/filter/Consumer.java b/example/src/main/java/org/apache/rocketmq/example/filter/Consumer.java index 0be8e1d388aa2d80bbbf1f5d6a08294e7dcc568c..bb491ac40af5a55b9667a4d4fb72c023ce91156c 100644 --- a/example/src/main/java/org/apache/rocketmq/example/filter/Consumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/filter/Consumer.java @@ -44,7 +44,7 @@ public class Consumer { @Override public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) { - System.out.printf(Thread.currentThread().getName() + " Receive New Messages: " + msgs + "%n"); + System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); diff --git a/example/src/main/java/org/apache/rocketmq/example/filter/SqlConsumer.java b/example/src/main/java/org/apache/rocketmq/example/filter/SqlConsumer.java index 8421675ced27d31f6b1109aa1e2c5ad1607026d6..c41c9c14c3c15b5a6e67f0c689cbc2bf1206c80a 100644 --- a/example/src/main/java/org/apache/rocketmq/example/filter/SqlConsumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/filter/SqlConsumer.java @@ -45,7 +45,7 @@ public class SqlConsumer { @Override public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) { - System.out.printf(Thread.currentThread().getName() + " Receive New Messages: " + msgs + "%n"); + System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); diff --git a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java index 44814bdeb4b38fb230fdda253190bb7078f0d607..abb274d6129278cb6e045ef503e7cdc88a79f912 100644 --- a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java @@ -41,7 +41,7 @@ public class Consumer { @Override public ConsumeOrderlyStatus consumeMessage(List msgs, ConsumeOrderlyContext context) { context.setAutoCommit(false); - System.out.printf(Thread.currentThread().getName() + " Receive New Messages: " + msgs + "%n"); + System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); this.consumeTimes.incrementAndGet(); if ((this.consumeTimes.get() % 2) == 0) { return ConsumeOrderlyStatus.SUCCESS; diff --git a/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java b/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java index 871edc28859bcb1833d4f713037591a92338c3c5..6d3b936507e9c667fdc816207f81d0f9502ecae2 100644 --- a/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java @@ -67,7 +67,7 @@ public class Consumer { @Override public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) { - System.out.printf(Thread.currentThread().getName() + " Receive New Messages: " + msgs + "%n"); + System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); diff --git a/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java b/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java index eb1cb759d849fe4206e2df0430bafb1c81591117..efffa36d59d58376a81b4381ca9225e97d08a6e5 100644 --- a/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java @@ -34,7 +34,7 @@ public class PullConsumer { Set mqs = consumer.fetchSubscribeMessageQueues("TopicTest1"); for (MessageQueue mq : mqs) { - System.out.printf("Consume from the queue: " + mq + "%n"); + System.out.printf("Consume from the queue: %s%n", mq); SINGLE_MQ: while (true) { try { diff --git a/example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java b/example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java index 43bbf6c36b59618e327fa86a67b48ac92bb2b81b..c6c7e39d174f849d5d98f5a448c880d3cf2caf82 100644 --- a/example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java @@ -37,7 +37,7 @@ public class PushConsumer { @Override public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) { - System.out.printf(Thread.currentThread().getName() + " Receive New Messages: " + msgs + "%n"); + System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); diff --git a/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionCheckListenerImpl.java b/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionCheckListenerImpl.java index 7b750969b60562b4dadd4e3b9705c8810b14308b..acb755ecfd73a7c6054b30d60c4476662327fb9d 100644 --- a/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionCheckListenerImpl.java +++ b/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionCheckListenerImpl.java @@ -26,7 +26,7 @@ public class TransactionCheckListenerImpl implements TransactionCheckListener { @Override public LocalTransactionState checkLocalTransactionState(MessageExt msg) { - System.out.printf("server checking TrMsg " + msg.toString() + "%n"); + System.out.printf("server checking TrMsg %s%n", msg); int value = transactionIndex.getAndIncrement(); if ((value % 6) == 0) { diff --git a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java index 41169c9a50a127544f442bad2b01a6456e729904..585024d4a77f67dc4a29192d69c2dc9bdd5571cb 100644 --- a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java +++ b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java @@ -92,7 +92,7 @@ public class FiltersrvStartup { Properties properties = new Properties(); properties.load(in); MixAll.properties2Object(properties, filtersrvConfig); - System.out.printf("load config properties file OK, " + file + "%n"); + System.out.printf("load config properties file OK, %s%n", file); in.close(); String port = properties.getProperty("listenPort"); @@ -116,8 +116,7 @@ public class FiltersrvStartup { MixAll.properties2Object(ServerUtil.commandLine2Properties(commandLine), filtersrvConfig); if (null == filtersrvConfig.getRocketmqHome()) { - System.out.printf("Please set the " + MixAll.ROCKETMQ_HOME_ENV - + " variable in your environment to match the location of the RocketMQ installation%n"); + System.out.printf("Please set the %s variable in your environment to match the location of the RocketMQ installation%n", MixAll.ROCKETMQ_HOME_ENV); System.exit(-2); } diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index f49d2b31ffe6dcac11fadb6262ef8aac43f73c97..760a61be02f1067c6e73ff072502eebdb3f1dbf3 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -96,7 +96,7 @@ public class NamesrvStartup { MixAll.properties2Object(ServerUtil.commandLine2Properties(commandLine), namesrvConfig); if (null == namesrvConfig.getRocketmqHome()) { - System.out.printf("Please set the " + MixAll.ROCKETMQ_HOME_ENV + " variable in your environment to match the location of the RocketMQ installation%n"); + System.out.printf("Please set the %s variable in your environment to match the location of the RocketMQ installation%n", MixAll.ROCKETMQ_HOME_ENV); System.exit(-2); } diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java index 6398291a06602dc3dbe5a14ed4fe37d5bb3b253a..517be4ebb7146a1ea778af291c472d13cb2282b0 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java @@ -19,8 +19,10 @@ package org.apache.rocketmq.tools.command; import ch.qos.logback.classic.LoggerContext; import ch.qos.logback.classic.joran.JoranConfigurator; import ch.qos.logback.core.joran.spi.JoranException; + import java.util.ArrayList; import java.util.List; + import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.Options; import org.apache.commons.cli.PosixParser; @@ -102,7 +104,7 @@ public class MQAdminStartup { ServerUtil.printCommandLineHelp("mqadmin " + cmd.commandName(), options); } } else { - System.out.printf("The sub command \'" + args[1] + "\' not exist.%n"); + System.out.printf("The sub command %s not exist.%n", args[1]); } break; } @@ -128,7 +130,7 @@ public class MQAdminStartup { cmd.execute(commandLine, options, rpcHook); } else { - System.out.printf("The sub command \'" + args[0] + "\' not exist.%n"); + System.out.printf("The sub command %s not exist.%n", args[0]); } break; } 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 e0a628aa4a433fec0b19ef2579e72b363b974525..69d3b24ca737b5b0c687281614addb63f9127554 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=" + result); + System.out.printf("rt:" + (System.currentTimeMillis() - begin) + "ms, SendResult=%s", result); } } catch (Exception e) { throw new SubCommandException(this.getClass().getSimpleName() + " command failed", e); diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java index 0e49c725fdfab5a902004ac47e6986675ea7a1f6..c212f0ee7f02a2d63d7177a47256b86e049d599f 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java @@ -115,7 +115,7 @@ public class ConsumerStatusSubCommand implements SubCommand { String result = ConsumerRunningInfo.analyzeProcessQueue(next.getKey(), next.getValue()); if (result.length() > 0) { - System.out.printf(result); + System.out.printf("%s", result); } } } else { diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java index 0eea98de9dd0d1b1c28872670f9a8946b9d2e3c2..a6df8ea8ecf45a93c52c8067f74dddd10fe956b6 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java @@ -114,7 +114,7 @@ public class ConsumerSubCommand implements SubCommand { String result = ConsumerRunningInfo.analyzeProcessQueue(next.getKey(), next.getValue()); if (result.length() > 0) { - System.out.printf(result); + System.out.printf("%s", result); } } } else { diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/DecodeMessageIdCommond.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/DecodeMessageIdCommond.java index d233b65aa948863dabe9e5054079819a1b1ca162..532508c0b266c259e2dddb1f15e5507afabcd066 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/DecodeMessageIdCommond.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/DecodeMessageIdCommond.java @@ -50,14 +50,14 @@ public class DecodeMessageIdCommond implements SubCommand { String messageId = commandLine.getOptionValue('i').trim(); try { - System.out.printf("ip=" + MessageClientIDSetter.getIPStrFromID(messageId)); + System.out.printf("ip=%s", MessageClientIDSetter.getIPStrFromID(messageId)); } catch (Exception e) { e.printStackTrace(); } try { String date = UtilAll.formatDate(MessageClientIDSetter.getNearlyTimeFromID(messageId), UtilAll.YYYY_MM_DD_HH_MM_SS_SSS); - System.out.printf("date=" + date); + System.out.printf("date=%s", date); } catch (Exception e) { throw new SubCommandException(this.getClass().getSimpleName() + " command failed", e); } diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java index d46d6fb629d610d150a2b1ea9685f9f2897adaa2..c8fced3b16e3d4baf99e579c12944d85b9597162 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java @@ -134,7 +134,7 @@ public class PrintMessageSubCommand implements SubCommand { maxOffset = consumer.searchOffset(mq, timeValue); } - System.out.printf("minOffset=" + minOffset + ", maxOffset=" + maxOffset + ", " + mq); + System.out.printf("minOffset=%s, maxOffset=%s, %s", minOffset, maxOffset, mq); READQ: for (long offset = minOffset; offset < maxOffset; ) { @@ -146,11 +146,11 @@ public class PrintMessageSubCommand implements SubCommand { printMessage(pullResult.getMsgFoundList(), charsetName, printBody); break; case NO_MATCHED_MSG: - System.out.printf(mq + " no matched msg. status=" + pullResult.getPullStatus() + ", offset=" + offset); + System.out.printf(mq + " no matched msg. status=%s, offset=%s", pullResult.getPullStatus(), offset); break; case NO_NEW_MSG: case OFFSET_ILLEGAL: - System.out.printf(mq + " print msg finished. status=" + pullResult.getPullStatus() + ", offset=" + offset); + System.out.printf(mq + " print msg finished. status=%s, offset=%s", pullResult.getPullStatus(), offset); break READQ; } } catch (Exception e) { diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java index 39abbc9c4c0bf754412a74e19485b8706e9d6f38..6bb8caad40ad5e4a89816f7f7c5f5a6003223b77 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java @@ -279,11 +279,11 @@ public class QueryMsgByIdSubCommand implements SubCommand { MessageExt msg = defaultMQAdminExt.viewMessage(msgId); if (msg != null) { // resend msg by id - System.out.printf("prepare resend msg. originalMsgId=" + msgId); + System.out.printf("prepare resend msg. originalMsgId=%s", msgId); SendResult result = defaultMQProducer.send(msg); System.out.printf("%s", result); } else { - System.out.printf("no message. msgId=" + msgId); + System.out.printf("no message. msgId=%s", msgId); } } catch (Exception e) { e.printStackTrace(); diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java index 9fdfcb38b244837554aec93579aef2dcb4abb737..8fdb9d3dbf8f64a63996a2c7537a694a6a4eeb62 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java @@ -169,8 +169,7 @@ public class UpdateTopicSubCommand implements SubCommand { } defaultMQAdminExt.createOrUpdateOrderConf(topicConfig.getTopicName(), orderConf.toString(), true); - System.out.printf(String.format("set cluster orderConf. isOrder=%s, orderConf=[%s]", - isOrder, orderConf.toString())); + System.out.printf("set cluster orderConf. isOrder=%s, orderConf=[%s]", isOrder, orderConf); } System.out.printf("%s", topicConfig);