Commit 870b9839 by liYao Committed by GitHub

原代码中使用了含有打点Cat的方法名。建议使用Monitor等抽象语义代替。

实际方法名由Apollo官方决定。
parent 1ca1b8d1
...@@ -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(() -> logWatchedKeysToMonitor(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"); logWatchedKeysToMonitor(watchedKeys, "Apollo.LongPoll.CompletedKeys");
}); });
logWatchedKeysToCat(watchedKeys, "Apollo.LongPoll.RegisteredKeys"); logWatchedKeysToMonitor(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 logWatchedKeysToMonitor(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