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);
}
}