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 2019/02/11 02:13:32 UTC
[rocketmq] branch snode updated: Removed console print in client
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch snode
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/snode by this push:
new 806f36b Removed console print in client
806f36b is described below
commit 806f36b4c702fc5417d9404cfa95ddef143d1406
Author: duhenglucky <du...@gmail.com>
AuthorDate: Mon Feb 11 10:11:29 2019 +0800
Removed console print in client
---
.../src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java | 1 -
.../java/org/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 00dcb36..ab93573 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 7f1496b..2f6ec28 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) {