You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2023/08/31 11:30:41 UTC
[dubbo] branch 3.2 updated: Publish directory refresh event after connectivity check (#12988)
This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch 3.2
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.2 by this push:
new 8d9817f8af Publish directory refresh event after connectivity check (#12988)
8d9817f8af is described below
commit 8d9817f8afa0329ef8d889d6e96d084a862b4a2e
Author: Albumen Kevin <jh...@gmail.com>
AuthorDate: Thu Aug 31 19:30:36 2023 +0800
Publish directory refresh event after connectivity check (#12988)
---
.../java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectory.java | 1 +
1 file changed, 1 insertion(+)
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 8f5875333f..dab89c0848 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
@@ -348,6 +348,7 @@ public abstract class AbstractDirectory<T> implements Directory<T> {
if (!invokersToReconnect.isEmpty()) {
checkConnectivity();
}
+ MetricsEventBus.publish(RegistryEvent.refreshDirectoryEvent(applicationModel, getSummary(), getDirectoryMeta()));
}, reconnectTaskPeriod, TimeUnit.MILLISECONDS);
}
MetricsEventBus.publish(RegistryEvent.refreshDirectoryEvent(applicationModel, getSummary(), getDirectoryMeta()));