diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectory.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectory.java index 4da81a0de8a..dbffbb2dc33 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectory.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectory.java @@ -306,7 +306,8 @@ public void addInvalidateInvoker(Invoker invoker) { // 3. try start check connectivity task checkConnectivity(); - logger.info("The invoker " + invoker.getUrl() + " has been added to invalidate list due to connectivity problem. " + logger.info("The invoker " + invoker.getUrl() + + " has been added to invalidate list due to connectivity problem. " + "Will trying to reconnect to it in the background."); } }); @@ -400,10 +401,10 @@ public void checkConnectivity() { */ public void refreshInvoker() { LockUtils.safeLock(invokerRefreshLock, 60_000, () -> { - if (invokersInitialized) { - refreshInvokerInternal(); - } - }); + if (invokersInitialized) { + refreshInvokerInternal(); + } + }); MetricsEventBus.publish( RegistryEvent.refreshDirectoryEvent(applicationModel, getSummary(), getDirectoryMeta())); }