(shardingsphere) branch master updated: Registry update event type for ListenerAssistedDispatchEvent (#31894)

[sunnianjun]

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

sunnianjun 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 d00291851da Registry update event type for 
ListenerAssistedDispatchEvent (#31894)
d00291851da is described below

commit d00291851dafea3f3979e380d62f29e8ec49074e
Author: Haoran Meng <menghaora...@gmail.com>
AuthorDate: Thu Jun 27 15:51:09 2024 +0800

    Registry update event type for ListenerAssistedDispatchEvent (#31894)
---
 .../mode/service/persist/ListenerAssistedPersistService.java           | 2 +-
 .../listener/watch/ListenerAssistedDispatchEventBuilder.java           | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/service/persist/ListenerAssistedPersistService.java
 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/service/persist/ListenerAssistedPersistService.java
index 1919d59c622..1c42665c967 100644
--- 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/service/persist/ListenerAssistedPersistService.java
+++ 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/service/persist/ListenerAssistedPersistService.java
@@ -37,7 +37,7 @@ public final class ListenerAssistedPersistService {
      * @param listenerAssistedPOJO listener assisted pojo
      */
     public void persistDatabaseNameListenerAssisted(final ListenerAssistedPOJO 
listenerAssistedPOJO) {
-        
repository.persist(ListenerAssistedNodePath.getDatabaseNameNodePath(listenerAssistedPOJO.getDatabaseName()),
 YamlEngine.marshal(listenerAssistedPOJO));
+        
repository.persistEphemeral(ListenerAssistedNodePath.getDatabaseNameNodePath(listenerAssistedPOJO.getDatabaseName()),
 YamlEngine.marshal(listenerAssistedPOJO));
     }
     
     /**
diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/watch/ListenerAssistedDispatchEventBuilder.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/watch/ListenerAssistedDispatchEventBuilder.java
index 3e3df169fee..c3d8397d07b 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/watch/ListenerAssistedDispatchEventBuilder.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/watch/ListenerAssistedDispatchEventBuilder.java
@@ -28,6 +28,7 @@ import 
org.apache.shardingsphere.mode.service.enums.ListenerAssistedEnum;
 import org.apache.shardingsphere.mode.service.pojo.ListenerAssistedPOJO;
 import org.apache.shardingsphere.mode.path.ListenerAssistedNodePath;
 
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Optional;
@@ -44,7 +45,7 @@ public class ListenerAssistedDispatchEventBuilder implements 
DispatchEventBuilde
     
     @Override
     public Collection<DataChangedEvent.Type> getSubscribedTypes() {
-        return Collections.singletonList(Type.ADDED);
+        return Arrays.asList(Type.ADDED, Type.UPDATED);
     }
     
     @Override