Skip to content

A
apollo
Commit cfe3ad66 by Jason Song Committed by GitHub
Options

Merge pull request #687 from powerYao/master

Cat单词不应出现在方法名，此处简化去除一下
parents 7fbd51fe e933a432
Showing with 4 additions and 4 deletions
apollo-configservice/src/main/java/com/ctrip/framework/apollo/configservice/controller/NotificationControllerV2.java
...@@ -159,17 +159,17 @@ public class NotificationControllerV2 implements ReleaseMessageListener { ...@@ -159,17 +159,17 @@ public class NotificationControllerV2 implements ReleaseMessageListener {
} }
deferredResult deferredResult
.onTimeout(() -> logWatchedKeysToCat(watchedKeys, "Apollo.LongPoll.TimeOutKeys")); .onTimeout(() -> logWatchedKeys(watchedKeys, "Apollo.LongPoll.TimeOutKeys"));
deferredResult.onCompletion(() -> { deferredResult.onCompletion(() -> {
//unregister all keys //unregister all keys
for (String key : watchedKeys) { for (String key : watchedKeys) {
deferredResults.remove(key, deferredResult); deferredResults.remove(key, deferredResult);
} }
logWatchedKeysToCat(watchedKeys, "Apollo.LongPoll.CompletedKeys"); logWatchedKeys(watchedKeys, "Apollo.LongPoll.CompletedKeys");
}); });
logWatchedKeysToCat(watchedKeys, "Apollo.LongPoll.RegisteredKeys"); logWatchedKeys(watchedKeys, "Apollo.LongPoll.RegisteredKeys");
logger.debug("Listening {} from appId: {}, cluster: {}, namespace: {}, datacenter: {}", logger.debug("Listening {} from appId: {}, cluster: {}, namespace: {}, datacenter: {}",
watchedKeys, appId, cluster, namespaces, dataCenter); watchedKeys, appId, cluster, namespaces, dataCenter);
} }
...@@ -278,7 +278,7 @@ public class NotificationControllerV2 implements ReleaseMessageListener { ...@@ -278,7 +278,7 @@ public class NotificationControllerV2 implements ReleaseMessageListener {
return keys.get(2); return keys.get(2);
}; };
private void logWatchedKeysToCat(Set<String> watchedKeys, String eventName) { private void logWatchedKeys(Set<String> watchedKeys, String eventName) {
for (String watchedKey : watchedKeys) { for (String watchedKey : watchedKeys) {
Tracer.logEvent(eventName, watchedKey); Tracer.logEvent(eventName, watchedKey);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment