完善观察者抽象.

hippo4j-common/src/main/java/cn/hippo4j/common/design/observer/AbstractSubjectCenter.java

@@ -29,6 +29,16 @@ public class AbstractSubjectCenter {
         register(SubjectType.SPRING_CONTENT_REFRESHED.name(), observer);
     }
 
+    /**
+     * Register observer.
+     *
+     * @param subjectType
+     * @param observer
+     */
+    public static void register(SubjectType subjectType, Observer observer) {
+        register(subjectType.name(), observer);
+    }
+
     /**
      * Register observer.
      *
@@ -75,6 +85,22 @@ public class AbstractSubjectCenter {
         observers.remove(observer);
     }
 
+    /**
+     * Notify.
+     *
+     * @param subjectType
+     * @param observerMessage
+     */
+    public static void notify(SubjectType subjectType, ObserverMessage observerMessage) {
+        notify(subjectType.name(), observerMessage);
+    }
+
+    /**
+     * Notify.
+     *
+     * @param subject
+     * @param observerMessage
+     */
     public static void notify(String subject, ObserverMessage observerMessage) {
         List<Observer> observers = OBSERVERS_MAP.get(subject);
         if (CollectionUtil.isEmpty(observers)) {
@@ -91,12 +117,17 @@ public class AbstractSubjectCenter {
         });
     }
 
-    private enum SubjectType {
+    public enum SubjectType {
 
         /**
          * Spring content refreshed.
          */
-        SPRING_CONTENT_REFRESHED
+        SPRING_CONTENT_REFRESHED,
+
+        /**
+         * Clear config cache.
+         */
+        CLEAR_CONFIG_CACHE
 
     }
 

hippo4j-common/src/main/java/cn/hippo4j/common/design/observer/Observer.java

@@ -6,13 +6,13 @@ package cn.hippo4j.common.design.observer;
  * @author chen.ma
  * @date 2021/12/25 19:46
  */
-public interface Observer {
+public interface Observer<T> {
 
     /**
      * Receive notification.
      *
      * @param observerMessage
      */
-    void accept(ObserverMessage observerMessage);
+    void accept(ObserverMessage<T> observerMessage);
 
 }

hippo4j-common/src/main/java/cn/hippo4j/common/design/observer/ObserverMessage.java

@@ -6,6 +6,13 @@ package cn.hippo4j.common.design.observer;
  * @author chen.ma
  * @date 2021/12/25 19:54
  */
-public interface ObserverMessage {
+public interface ObserverMessage<T> {
+
+    /**
+     * Message.
+     *
+     * @return
+     */
+    T message();
 
 }