diff --git a/apollo-configservice/src/main/java/com/ctrip/framework/apollo/configservice/controller/NotificationControllerV2.java b/apollo-configservice/src/main/java/com/ctrip/framework/apollo/configservice/controller/NotificationControllerV2.java index 5a9f9b2674f43fd52113833c8c3f6813d6ccf502..a466bcee48b80324674689991be1bd2a1b061a76 100644 --- a/apollo-configservice/src/main/java/com/ctrip/framework/apollo/configservice/controller/NotificationControllerV2.java +++ b/apollo-configservice/src/main/java/com/ctrip/framework/apollo/configservice/controller/NotificationControllerV2.java @@ -159,17 +159,17 @@ public class NotificationControllerV2 implements ReleaseMessageListener { } deferredResult - .onTimeout(() -> logWatchedKeysToCat(watchedKeys, "Apollo.LongPoll.TimeOutKeys")); + .onTimeout(() -> logWatchedKeys(watchedKeys, "Apollo.LongPoll.TimeOutKeys")); deferredResult.onCompletion(() -> { //unregister all keys for (String key : watchedKeys) { 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: {}", watchedKeys, appId, cluster, namespaces, dataCenter); } @@ -278,7 +278,7 @@ public class NotificationControllerV2 implements ReleaseMessageListener { return keys.get(2); }; - private void logWatchedKeysToCat(Set watchedKeys, String eventName) { + private void logWatchedKeys(Set watchedKeys, String eventName) { for (String watchedKey : watchedKeys) { Tracer.logEvent(eventName, watchedKey); }