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 2bc27f15598 Rename GlobalMetaDataChangedListener (#34250)
2bc27f15598 is described below
commit 2bc27f155983129094ac8b1055b19967be7abc59
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Jan 4 23:55:27 2025 +0800
Rename GlobalMetaDataChangedListener (#34250)
---
.../cluster/dispatch/listener/DataChangedEventListenerRegistry.java | 4 ++--
...MetaDataChangedHandler.java => GlobalMetaDataChangedListener.java} | 4 ++--
.../dispatch/listener/DataChangedEventListenerRegistryTest.java | 4 ++--
3 files changed, 6 insertions(+), 6 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 d6d4fc460ef..715e4e1c2db 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
@@ -22,7 +22,7 @@ import
org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.DataChangedEventHandler;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.DatabaseMetaDataChangedListener;
-import
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedHandler;
+import
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedListener;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import java.util.Collection;
@@ -57,6 +57,6 @@ public final class DataChangedEventListenerRegistry {
}
private void registerGlobalHandlers(final DataChangedEventHandler handler)
{
- repository.watch(handler.getSubscribedKey(), new
GlobalMetaDataChangedHandler(contextManager, handler));
+ repository.watch(handler.getSubscribedKey(), new
GlobalMetaDataChangedListener(contextManager, handler));
}
}
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedListener.java
similarity index 93%
rename from
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedHandler.java
rename to
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedListener.java
index c067e6fa2f3..bd5e427f248 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedListener.java
@@ -25,10 +25,10 @@ import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.DataChang
import
org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener;
/**
- * Global meta data changed handler.
+ * Global meta data changed listener.
*/
@RequiredArgsConstructor
-public final class GlobalMetaDataChangedHandler implements
DataChangedEventListener {
+public final class GlobalMetaDataChangedListener implements
DataChangedEventListener {
private final ContextManager contextManager;
diff --git
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
index 620aef5d8cf..206793f2071 100644
---
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
+++
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.DatabaseMetaDataChangedListener;
-import
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedHandler;
+import
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedListener;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import org.junit.jupiter.api.Test;
@@ -44,6 +44,6 @@ class DataChangedEventListenerRegistryTest {
DataChangedEventListenerRegistry registry = new
DataChangedEventListenerRegistry(contextManager,
Collections.singleton("foo_db"));
registry.register();
verify(repository).watch(eq("/metadata/foo_db"),
any(DatabaseMetaDataChangedListener.class));
- verify(repository, atLeastOnce()).watch(anyString(),
any(GlobalMetaDataChangedHandler.class));
+ verify(repository, atLeastOnce()).watch(anyString(),
any(GlobalMetaDataChangedListener.class));
}
}