You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2025/03/25 06:15:22 UTC
(shardingsphere) branch master updated: Refactor DataChangedEventListenerRegistry (#35073)
This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 8d1940bdcd6 Refactor DataChangedEventListenerRegistry (#35073)
8d1940bdcd6 is described below
commit 8d1940bdcd60f6a01280b3d791bb2b85a34a6f02
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Tue Mar 25 14:15:16 2025 +0800
Refactor DataChangedEventListenerRegistry (#35073)
---
.../cluster/dispatch/listener/DataChangedEventListenerRegistry.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java
index 8b309f81134..6126af252bd 100644
--- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java
+++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java
@@ -50,14 +50,14 @@ public final class DataChangedEventListenerRegistry {
*/
public void register() {
databaseNames.forEach(this::registerDatabaseListeners);
- ShardingSphereServiceLoader.getServiceInstances(GlobalDataChangedEventHandler.class).forEach(this::registerGlobalHandlers);
+ ShardingSphereServiceLoader.getServiceInstances(GlobalDataChangedEventHandler.class).forEach(this::registerGlobalListeners);
}
private void registerDatabaseListeners(final String databaseName) {
repository.watch(NodePathGenerator.toPath(new DatabaseMetaDataNodePath(databaseName)), new DatabaseMetaDataChangedListener(contextManager));
}
- private void registerGlobalHandlers(final GlobalDataChangedEventHandler handler) {
+ private void registerGlobalListeners(final GlobalDataChangedEventHandler handler) {
repository.watch(NodePathGenerator.toPath(handler.getSubscribedNodePath()), new GlobalMetaDataChangedListener(contextManager, handler));
}
}