From 87574c54b7e131269607b12a6ed42459bc67f431 Mon Sep 17 00:00:00 2001 From: Albumen Kevin Date: Wed, 21 Feb 2024 11:27:48 +0800 Subject: [PATCH] style --- .../rpc/cluster/directory/AbstractDirectory.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) 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())); }