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 2c9996ef048 Refactor DatabaseMetaDataChangedListener (#34061)
2c9996ef048 is described below

commit 2c9996ef048076fb5776051dee8f019addad0774
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Dec 14 23:08:29 2024 +0800

    Refactor DatabaseMetaDataChangedListener (#34061)
---
 .../dispatch/listener/type/DatabaseMetaDataChangedListener.java   | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/type/DatabaseMetaDataChangedListener.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/type/DatabaseMetaDataChangedListener.java
index e0d6c155378..8d8d0f46f47 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/type/DatabaseMetaDataChangedListener.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/type/DatabaseMetaDataChangedListener.java
@@ -34,10 +34,6 @@ import java.util.Optional;
 @RequiredArgsConstructor
 public final class DatabaseMetaDataChangedListener implements 
DataChangedEventListener {
     
-    private final MetaDataChangedEventBuilder metaDataChangedEventBuilder = 
new MetaDataChangedEventBuilder();
-    
-    private final RuleConfigurationChangedEventBuilder 
ruleConfigChangedEventBuilder = new RuleConfigurationChangedEventBuilder();
-    
     private final EventBusContext eventBusContext;
     
     @Override
@@ -51,7 +47,7 @@ public final class DatabaseMetaDataChangedListener implements 
DataChangedEventLi
         if (!databaseName.isPresent()) {
             return Optional.empty();
         }
-        Optional<DispatchEvent> metaDataChangedEvent = 
metaDataChangedEventBuilder.build(databaseName.get(), event);
-        return metaDataChangedEvent.isPresent() ? metaDataChangedEvent : 
ruleConfigChangedEventBuilder.build(databaseName.get(), event);
+        Optional<DispatchEvent> metaDataChangedEvent = new 
MetaDataChangedEventBuilder().build(databaseName.get(), event);
+        return metaDataChangedEvent.isPresent() ? metaDataChangedEvent : new 
RuleConfigurationChangedEventBuilder().build(databaseName.get(), event);
     }
 }

Reply via email to