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 2021/02/04 10:43:16 UTC

[shardingsphere] branch master updated: Rename SchemasChangedListener to MetaDataChangedListener (#9324)

This is an automated email from the ASF dual-hosted git repository.

zhangyonglun 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 141a3a5  Rename SchemasChangedListener to MetaDataChangedListener (#9324)
141a3a5 is described below

commit 141a3a5bfd1b995192ad923e428ee47d1dae47c9
Author: Haoran Meng <me...@gmail.com>
AuthorDate: Thu Feb 4 18:42:55 2021 +0800

    Rename SchemasChangedListener to MetaDataChangedListener (#9324)
---
 .../{SchemasChangedListener.java => MetaDataChangedListener.java}   | 4 ++--
 .../governance/core/config/listener/metadata/MetaDataListener.java  | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/SchemasChangedListener.java b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataChangedListener.java
similarity index 93%
rename from shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/SchemasChangedListener.java
rename to shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataChangedListener.java
index 0e461de..fe56c17 100644
--- a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/SchemasChangedListener.java
+++ b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataChangedListener.java
@@ -36,13 +36,13 @@ import java.util.Set;
 /**
  * Schemas changed listener.
  */
-public final class SchemasChangedListener extends PostGovernanceRepositoryEventListener<GovernanceEvent> {
+public final class MetaDataChangedListener extends PostGovernanceRepositoryEventListener<GovernanceEvent> {
     
     private final Collection<String> existedSchemaNames;
     
     private final ConfigCenterNode configurationNode;
     
-    public SchemasChangedListener(final ConfigurationRepository configurationRepository, final Collection<String> schemaNames) {
+    public MetaDataChangedListener(final ConfigurationRepository configurationRepository, final Collection<String> schemaNames) {
         super(configurationRepository, Collections.singleton(new ConfigCenterNode().getMetadataNodePath()));
         configurationNode = new ConfigCenterNode();
         existedSchemaNames = new LinkedHashSet<>(schemaNames);
diff --git a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java
index 1eaf6e1..b28212b 100644
--- a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java
+++ b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java
@@ -30,7 +30,7 @@ import java.util.Collection;
  */
 public final class MetaDataListener {
     
-    private final SchemasChangedListener schemasChangedListener;
+    private final MetaDataChangedListener metaDataChangedListener;
     
     private volatile RuleChangedListener ruleChangedListener;
     
@@ -42,7 +42,7 @@ public final class MetaDataListener {
     
     public MetaDataListener(final ConfigurationRepository configurationRepository, final Collection<String> schemaNames) {
         this.configurationRepository = configurationRepository;
-        schemasChangedListener = new SchemasChangedListener(configurationRepository, schemaNames);
+        metaDataChangedListener = new MetaDataChangedListener(configurationRepository, schemaNames);
         ruleChangedListener = new RuleChangedListener(configurationRepository, schemaNames);
         dataSourceChangedListener = new DataSourceChangedListener(configurationRepository, schemaNames);
         schemaChangedListener = new SchemaChangedListener(configurationRepository, schemaNames);
@@ -53,7 +53,7 @@ public final class MetaDataListener {
      * watch event.
      */
     public void watch() {
-        schemasChangedListener.watch(Type.UPDATED);
+        metaDataChangedListener.watch(Type.UPDATED);
         ruleChangedListener.watch(Type.UPDATED);
         dataSourceChangedListener.watch(Type.UPDATED);
         schemaChangedListener.watch(Type.UPDATED);