From 274d91f5c1d85c6ae20a4ba932d6e245f1eb7f52 Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期五, 20 四月 2018 18:52:51 +0800
Subject: [PATCH] 增加sql配置查询，查询类测试通过
---
java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java b/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java
index 587d421..50233df 100644
--- a/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java
+++ b/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java
@@ -116,7 +116,7 @@
*/
public static Class<DataFlowEvent> getEvent(String serviceCode) throws BusinessException{
Class<DataFlowEvent> targetEvent = events.get(serviceCode);
- Assert.notNull(targetEvent,"鏀规湇鍔℃湭娉ㄥ唽璇ヤ簨浠禰serviceCode = "+serviceCode+"]锛岀郴缁熺洰鍓嶄笉鏀寔!");
+ //Assert.notNull(targetEvent,"鏀规湇鍔℃湭娉ㄥ唽璇ヤ簨浠禰serviceCode = "+serviceCode+"]锛岀郴缁熺洰鍓嶄笉鏀寔!");
return targetEvent;
}
@@ -139,6 +139,10 @@
try {
Class<DataFlowEvent> dataFlowEventClass = getEvent(serviceCode);
+ if(dataFlowEventClass == null){
+ return ;
+ }
+
Class[] parameterTypes = {Object.class, DataFlow.class};
Constructor constructor = dataFlowEventClass.getClass().getConstructor(parameterTypes);
--
Gitblit v1.8.0