diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventCustom.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventCustom.java new file mode 100644 index 0000000..83b1028 --- /dev/null +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventCustom.java @@ -0,0 +1,24 @@ +package com.muyu.processing.basic; + +import cn.hutool.json.JSONObject; +import org.springframework.context.ApplicationEvent; + +/** + * 事件类型 + * @Author:杨鹏 + * @Package:com.muyu.processing.basic + * @Project:car-cloud-server + * @name:EventCustom + * @Date:2024/9/29 21:18 + */ +public class EventCustom extends ApplicationEvent{ + private JSONObject data; + public EventCustom(Object source, JSONObject data) { + super(source); + this.data = data; + } + + public JSONObject getData(){ + return data; + } +} diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventListener.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventListener.java new file mode 100644 index 0000000..a75baee --- /dev/null +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventListener.java @@ -0,0 +1,16 @@ +package com.muyu.processing.basic; + +import org.springframework.context.ApplicationListener; + +/** + * 事件监听接口 + * @Author:杨鹏 + * @Package:com.muyu.processing.basic + * @Project:car-cloud-server + * @name:EventListener + * @Date:2024/9/29 22:29 + */ +public interface EventListener extends ApplicationListener { + void onEvent(EventCustom event); + +} diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventPublisher.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventPublisher.java new file mode 100644 index 0000000..2551004 --- /dev/null +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/basic/EventPublisher.java @@ -0,0 +1,23 @@ +package com.muyu.processing.basic; + +import org.springframework.context.ApplicationEventPublisher; +import org.springframework.context.ApplicationEventPublisherAware; + +/** + * 策略发送事件 + * @Author:杨鹏 + * @Package:com.muyu.processing.basic + * @Project:car-cloud-server + * @name:EventPublisher + * @Date:2024/9/29 22:31 + */ +public class EventPublisher implements ApplicationEventPublisherAware { + + private ApplicationEventPublisher publisher; + + @Override + public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher){ + this.publisher = applicationEventPublisher; + } + +}