Merge 9c1f2f6 into 265bf6e

opengoofy · Nov 2, 2023 · ac7d69a · ac7d69a
2 parents 265bf6e + 9c1f2f6
commit ac7d69a
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) {