From 9c1f2f63633d4b7709daf8ae1b4f2458321b0731 Mon Sep 17 00:00:00 2001
From: zolmk <cxy52768915>
Date: Thu, 2 Nov 2023 17:06:47 +0800
Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9AAdding=20two=20or=20more=20publishe?=
 =?UTF-8?q?rs=20is=20an=20error?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/cn/hippo4j/config/notify/NotifyCenter.java | 5 +++--
 1 file changed, 3 insertions(+), 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
index 6c7c6ab5..9f1b354d 100644
--- 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 lombok.extern.slf4j.Slf4j;
 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) {