From 73d769f8394036291b679e4e645d1af0a9f5db99 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 12 九月 2021 22:39:02 +0800
Subject: [PATCH] cmd 调试完成
---
java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java | 15 ++++++++-------
1 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java b/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java
index 990e21a..28e8ac0 100644
--- a/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java
+++ b/java110-core/src/main/java/com/java110/core/event/cmd/ServiceCmdEventPublishing.java
@@ -6,6 +6,7 @@
import com.java110.core.event.center.DataFlowListenerOrderComparator;
import com.java110.core.event.service.api.ServiceDataFlowEvent;
import com.java110.core.event.service.api.ServiceDataFlowListener;
+import com.java110.dto.CmdListenerDto;
import com.java110.entity.center.AppService;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.constant.ResponseConstant;
@@ -20,6 +21,7 @@
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpMethod;
+import java.lang.annotation.Annotation;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -42,7 +44,7 @@
/**
* 淇濆瓨渚﹀惉瀹炰緥淇℃伅锛屼竴鑸惎鍔ㄦ椂鍔犺浇
*/
- private static final List<String> listeners = new ArrayList<String>();
+ private static final List<CmdListenerDto> listeners = new ArrayList<CmdListenerDto>();
/**
* 鏍规嵁 浜嬩欢绫诲瀷鏌ヨ渚﹀惉
@@ -54,7 +56,7 @@
*
* @param listener
*/
- public static void addListener(String listener) {
+ public static void addListener(CmdListenerDto listener) {
listeners.add(listener);
}
@@ -63,7 +65,7 @@
*
* @return
*/
- public static List<String> getListeners() {
+ public static List<CmdListenerDto> getListeners() {
return listeners;
}
@@ -85,10 +87,9 @@
}
List<ServiceCmdListener> cmdListeners = new ArrayList<ServiceCmdListener>();
- for (String listenerBeanName : getListeners()) {
- ServiceCmdListener listener = ApplicationContextFactory.getBean(listenerBeanName, ServiceCmdListener.class);
- Java110Cmd java110Cmd = listener.getClass().getDeclaredAnnotation(Java110Cmd.class);
- if(java110Cmd.serviceCode().equals(serviceCode)) {
+ for (CmdListenerDto listenerBean : getListeners()) {
+ ServiceCmdListener listener = ApplicationContextFactory.getBean(listenerBean.getBeanName(), ServiceCmdListener.class);
+ if(listenerBean.getServiceCode().equals(serviceCode)) {
cmdListeners.add(listener);
}
}
--
Gitblit v1.8.0