From 806f36b4c702fc5417d9404cfa95ddef143d1406 Mon Sep 17 00:00:00 2001 From: duhenglucky Date: Mon, 11 Feb 2019 10:11:29 +0800 Subject: [PATCH] Removed console print in client --- .../java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java | 1 - .../apache/rocketmq/client/impl/factory/MQClientInstance.java | 1 - 2 files changed, 2 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java index 00dcb36c..ab935730 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java @@ -2121,7 +2121,6 @@ public class MQClientAPIImpl { RemotingCommand response = this.remotingClient.invokeSync(address, request, timeoutMillis); assert response != null; - System.out.println("create retry topic for consumerGrouop: " + consumerGroup); if (ResponseCode.SUCCESS != response.getCode()) { throw new MQClientException(response.getCode(), response.getRemark()); } diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java index 7f1496bd..2f6ec288 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java @@ -1284,7 +1284,6 @@ public class MQClientInstance { public void createRetryTopic(String topic, String consumerGroup) { - System.out.println("****create retry topic for consumerGrouop: " + consumerGroup); TopicRouteData topicRouteData = this.topicRouteTable.get(topic); if (topicRouteData != null) { if (topicRouteData.getBrokerDatas() != null) { -- GitLab