From a0c2d916f2dffa92dcbb35e218a10000d4a7a97f Mon Sep 17 00:00:00 2001
From: xinzirun <xinzirun0227@163.com>
Date: Mon, 7 Oct 2024 09:01:19 +0800
Subject: [PATCH] =?UTF-8?q?fix():=20=E4=BF=AE=E6=94=B9=E4=BA=8B=E4=BB=B6?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E5=9F=BA=E7=B1=BB=E6=9E=B6=E6=9E=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../event/process/basic/BasicEventHandler.java     | 14 ++++++++------
 ...BInsertDataEvent.java => DataProcessEvent.java} |  8 ++++----
 2 files changed, 12 insertions(+), 10 deletions(-)
 rename cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/event/{IoTDBInsertDataEvent.java => DataProcessEvent.java} (50%)

diff --git a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/basic/BasicEventHandler.java b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/basic/BasicEventHandler.java
index 0b0e7bf..a7d91f4 100644
--- a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/basic/BasicEventHandler.java
+++ b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/basic/BasicEventHandler.java
@@ -3,6 +3,8 @@ package com.muyu.event.process.basic;
 import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 /**
  * @Author: zi run
  * @Date 2024/9/30 15:37
@@ -12,17 +14,17 @@ import org.springframework.stereotype.Component;
 public class BasicEventHandler<T> implements ApplicationListener<BasicEvent<T>> {
 
     /**
-     * 具体事件监听器
+     * 具体事件监听器列表
      */
-    private final BasicEventListener<T> listener;
+    private final List<BasicEventListener<T>> listeners;
 
     /**
      * 构造函数，用于注入具体事件监听器
      *
-     * @param listener 具体事件监听器
+     * @param listeners 具体事件监听器列表
      */
-    public BasicEventHandler(BasicEventListener<T> listener) {
-        this.listener = listener;
+    public BasicEventHandler(List<BasicEventListener<T>> listeners) {
+        this.listeners = listeners;
     }
 
     /**
@@ -32,6 +34,6 @@ public class BasicEventHandler<T> implements ApplicationListener<BasicEvent<T>>
      */
     @Override
     public void onApplicationEvent(BasicEvent<T> event) {
-        listener.onEvent(event);
+        listeners.forEach(l -> l.onEvent(event));
     }
 }
\ No newline at end of file
diff --git a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/event/IoTDBInsertDataEvent.java b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/event/DataProcessEvent.java
similarity index 50%
rename from cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/event/IoTDBInsertDataEvent.java
rename to cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/event/DataProcessEvent.java
index 2253da6..658d645 100644
--- a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/event/IoTDBInsertDataEvent.java
+++ b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/event/DataProcessEvent.java
@@ -5,16 +5,16 @@ import com.muyu.event.process.basic.BasicEvent;
 /**
  * @Author: zi run
  * @Date 2024/9/29 21:19
- * @Description 向IoTDB插入数据事件
+ * @Description 数据处理事件
  */
-public class IoTDBInsertDataEvent extends BasicEvent<String> {
+public class DataProcessEvent extends BasicEvent<String> {
 
     /**
-     * 构造函数，向IoTDB插入数据创建事件
+     * 构造函数，数据处理创建事件
      *
      * @param messsge 消息
      */
-    public IoTDBInsertDataEvent(Object source, String messsge) {
+    public DataProcessEvent(Object source, String messsge) {
         super(source, messsge);
     }
 }
\ No newline at end of file