|
@ -1,6 +1,5 @@
|
|
package com.yihu.hos.common.listener;
|
|
package com.yihu.hos.common.listener;
|
|
|
|
|
|
import com.yihu.hos.common.configuration.ActivemqConfiguration;
|
|
|
|
import com.yihu.hos.common.constants.Constant;
|
|
import com.yihu.hos.common.constants.Constant;
|
|
import com.yihu.hos.common.dao.BrokerDao;
|
|
import com.yihu.hos.common.dao.BrokerDao;
|
|
import com.yihu.hos.core.datatype.ClassFileUtil;
|
|
import com.yihu.hos.core.datatype.ClassFileUtil;
|
|
@ -9,15 +8,12 @@ import com.yihu.hos.models.SystemCamelContext;
|
|
import com.yihu.hos.models.SystemClassMapping;
|
|
import com.yihu.hos.models.SystemClassMapping;
|
|
import com.yihu.hos.models.SystemServiceFlow;
|
|
import com.yihu.hos.models.SystemServiceFlow;
|
|
import com.yihu.hos.models.SystemServiceFlowClass;
|
|
import com.yihu.hos.models.SystemServiceFlowClass;
|
|
import org.apache.activemq.ActiveMQConnectionFactory;
|
|
|
|
import org.apache.camel.builder.RouteBuilder;
|
|
import org.apache.camel.builder.RouteBuilder;
|
|
import org.apache.camel.component.jms.JmsComponent;
|
|
|
|
import org.apache.log4j.LogManager;
|
|
import org.apache.log4j.LogManager;
|
|
import org.apache.log4j.Logger;
|
|
import org.apache.log4j.Logger;
|
|
import org.springframework.context.ApplicationListener;
|
|
import org.springframework.context.ApplicationListener;
|
|
import org.springframework.context.event.ContextRefreshedEvent;
|
|
import org.springframework.context.event.ContextRefreshedEvent;
|
|
|
|
|
|
import javax.jms.ConnectionFactory;
|
|
|
|
import java.io.File;
|
|
import java.io.File;
|
|
import java.net.URL;
|
|
import java.net.URL;
|
|
import java.net.URLClassLoader;
|
|
import java.net.URLClassLoader;
|
|
@ -110,12 +106,7 @@ public class ApplicationStartListener implements ApplicationListener<ContextRefr
|
|
// 4、=============
|
|
// 4、=============
|
|
// 首先启动Apache Camel服务
|
|
// 首先启动Apache Camel服务
|
|
SystemCamelContext.getDefaultCamelContext().start();
|
|
SystemCamelContext.getDefaultCamelContext().start();
|
|
ActivemqConfiguration activemqConfiguration = contextRefreshedEvent.getApplicationContext().getBean(ActivemqConfiguration.class);
|
|
|
|
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
|
|
|
|
activemqConfiguration.getUser(), activemqConfiguration.getPassword(), activemqConfiguration.getBrokerURL());
|
|
|
|
// Note we can explicit name the component
|
|
|
|
SystemCamelContext.getDefaultCamelContext().addComponent("business-log", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
|
|
|
|
|
|
|
|
|
|
SystemCamelContext.getDefaultCamelContext().setUseMDCLogging(true);
|
|
logger.info("Apache Camel Context 启动完成......");
|
|
logger.info("Apache Camel Context 启动完成......");
|
|
// 加载和设置ClassLoader
|
|
// 加载和设置ClassLoader
|
|
List<URL> URLs = new ArrayList<>();
|
|
List<URL> URLs = new ArrayList<>();
|