From 573d22f534116ed01056869f2299f37d04b8ddb6 Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期日, 13 五月 2018 23:58:55 +0800
Subject: [PATCH] 完成控制服务前台操作配置数据功能
---
java110-event/src/main/java/com/java110/event/center/init/EventConfigInit.java | 52 ++++++++--------------------------------------------
1 files changed, 8 insertions(+), 44 deletions(-)
diff --git a/java110-event/src/main/java/com/java110/event/center/init/CenterServiceStartInit.java b/java110-event/src/main/java/com/java110/event/center/init/EventConfigInit.java
similarity index 66%
rename from java110-event/src/main/java/com/java110/event/center/init/CenterServiceStartInit.java
rename to java110-event/src/main/java/com/java110/event/center/init/EventConfigInit.java
index c3ee7d2..7da1db3 100644
--- a/java110-event/src/main/java/com/java110/event/center/init/CenterServiceStartInit.java
+++ b/java110-event/src/main/java/com/java110/event/center/init/EventConfigInit.java
@@ -1,15 +1,10 @@
package com.java110.event.center.init;
import com.java110.common.factory.ApplicationContextFactory;
-import com.java110.entity.center.DataFlow;
import com.java110.event.app.AppEventPublishing;
-import com.java110.event.app.AppListener;
import com.java110.event.center.DataFlowEventPublishing;
import com.java110.event.center.DataFlowListener;
-import com.java110.event.listener.common.CommonDispatchListener;
import org.apache.commons.lang3.StringUtils;
-import org.springframework.boot.context.event.ApplicationReadyEvent;
-import org.springframework.context.ApplicationContext;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.support.PropertiesLoaderUtils;
@@ -20,18 +15,18 @@
* 绯荤粺鍚姩鏃跺姞杞戒俊鎭�
* Created by wuxw on 2017/4/14.
*/
-public class CenterServiceStartInit {
+public class EventConfigInit {
/**
* 榛樿 浜嬩欢閰嶇疆璺緞classpath:/
*/
- private final String DEFAULT_EVENT_PATH = "config/";
+ private final static String DEFAULT_EVENT_PATH = "config/";
/**
* 榛樿 鏂囦欢鍚嶇О .properties
*/
- private final String DEFAULT_FILE_NAME = "center_event.properties";
+ private final static String DEFAULT_FILE_NAME = "center_event.properties";
/**
* 璁㈠崟璋冨害澶勭悊渚﹀惉
@@ -44,42 +39,11 @@
private final static String DISPATCH_EVENT = "java110.event.properties.centerServiceEvent";
-
-
- /**
- * 鍔犺浇閰嶇疆鏂囦欢锛屽皢渚﹀惉鍒濆鍖�
- * @param event
- */
- // @Override
- public void onApplicationEvent(ApplicationReadyEvent event){
-
-
+ public static void initSystemConfig(){
//鍔犺浇閰嶇疆鏂囦欢锛屾敞鍐岃鍗曞鐞嗕睛鍚�
try {
- ApplicationContextFactory.setApplicationContext(event.getApplicationContext());
-
- Properties properties = this.load(DEFAULT_EVENT_PATH,DEFAULT_FILE_NAME);
-
- registerListener(properties);
-
- //娉ㄥ唽浜嬩欢
- registerEvent(properties);
-
- }
- catch (Exception ex) {
- throw new IllegalStateException("system init error", ex);
- }
-
- }
-
- public void initSystemConfig(ApplicationContext context){
- //鍔犺浇閰嶇疆鏂囦欢锛屾敞鍐岃鍗曞鐞嗕睛鍚�
- try {
-
- ApplicationContextFactory.setApplicationContext(context);
-
- Properties properties = this.load(DEFAULT_EVENT_PATH,DEFAULT_FILE_NAME);
+ Properties properties = load(DEFAULT_EVENT_PATH,DEFAULT_FILE_NAME);
registerListener(properties);
@@ -99,7 +63,7 @@
* @param filename
* @param
*/
- private Properties load(String location,String filename) throws Exception{
+ private static Properties load(String location,String filename) throws Exception{
Properties properties = PropertiesLoaderUtils.loadProperties(new ClassPathResource(location+filename));
return properties;
}
@@ -108,7 +72,7 @@
* 娉ㄥ唽渚﹀惉
* @param properties
*/
- private void registerListener(Properties properties) throws Exception{
+ private static void registerListener(Properties properties) throws Exception{
String[] listeners = properties.getProperty(DATAFLOW_LISTENER).split("\\,");
@@ -128,7 +92,7 @@
* @param properties
* @throws Exception
*/
- private void registerEvent(Properties properties) throws Exception{
+ private static void registerEvent(Properties properties) throws Exception{
String[] events = properties.getProperty(DISPATCH_EVENT).split("\\,");
for (String event : events){
--
Gitblit v1.8.0