opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-30 18:44:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ROCKETMQ-37] Polish log output information in MQClientManager, closes apache/incubator-rocketmq#33, closes apache/incubator-rocketmq#26

Browse Source
This commit is contained in:
a2888409
2017-01-20 10:55:48 +08:00
committed by yukon
parent 4291348ef7
commit 69361f60b7
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
+1 -1
View File
@@ -184,7 +184,7 @@ public class SubscriptionGroupManager extends ConfigManager {
this.dataVersion.nextVersion();
this.persist();
} else {
log.warn("delete subscription group failed, subscription group: {} not exist", old);
log.warn("delete subscription group failed, subscription groupName: {} not exist", groupName);
}
}
}
client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java
+2 -1
View File
@@ -53,8 +53,9 @@ public class MQClientManager {
MQClientInstance prev = this.factoryTable.putIfAbsent(clientId, instance);
if (prev != null) {
instance = prev;
log.warn("Returned Previous MQClientInstance for clientId:[{}]", clientId);
} else {
log.warn("Previous MQClientInstance has created for clientId:[{}]", clientId);
log.info("Created new MQClientInstance for clientId:[{}]", clientId);
}
}