fix：Adding two or more publishers is an error

opengoofy · Nov 2, 2023 · 9c1f2f6 · 9c1f2f6
1 parent 265bf6e
commit 9c1f2f6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/threadpool/server/config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java b/threadpool/server/config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java
@@ -28,6 +28,7 @@
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.BiFunction;
+import java.util.function.Supplier;
 
 /**
  * Unified event notify center.
@@ -43,7 +44,7 @@ public class NotifyCenter {
 
     private DefaultSharePublisher sharePublisher;
 
-    private static EventPublisher eventPublisher = new DefaultPublisher();
+    private static final Supplier<EventPublisher> publisherSupplier = DefaultPublisher::new;
 
     private static BiFunction<Class<? extends AbstractEvent>, Integer, EventPublisher> publisherFactory;
 
@@ -52,7 +53,7 @@ public class NotifyCenter {
     static {
         publisherFactory = (cls, buffer) -> {
             try {
-                EventPublisher publisher = eventPublisher;
+                EventPublisher publisher = publisherSupplier.get();
                 publisher.init(cls, buffer);
                 return publisher;
             } catch (Throwable ex) {