| | |
| | | package com.java110.event.service.init; |
| | | |
| | | import com.java110.common.util.Assert; |
| | | import com.java110.common.factory.ApplicationContextFactory; |
| | | import com.java110.utils.util.Assert; |
| | | import com.java110.event.service.BusinessServiceDataFlowEventPublishing; |
| | | import com.java110.event.service.BusinessServiceDataFlowListener; |
| | | import org.springframework.core.io.ClassPathResource; |
| | | import org.springframework.core.io.support.PropertiesLoaderUtils; |
| | | |
| | |
| | | //这里不能直接反射,这样 IXXXService 无法注入,所以直接从spring 中获取已经注入的 |
| | | //AppListener<?> appListener = (AppListener<?>)Class.forName(listener).newInstance(); |
| | | try { |
| | | BusinessServiceDataFlowListener businessServiceDataFlowListener = (BusinessServiceDataFlowListener) ApplicationContextFactory.getBean(listener); |
| | | // BusinessServiceDataFlowListener businessServiceDataFlowListener = (BusinessServiceDataFlowListener) ApplicationContextFactory.getBean(listener); |
| | | //将 listener 放入 AppEventPublishing 中方便后期操作 |
| | | //注册侦听 |
| | | BusinessServiceDataFlowEventPublishing.addListenner(businessServiceDataFlowListener); |
| | | BusinessServiceDataFlowEventPublishing.addListener(listener); |
| | | }catch (Exception e){ |
| | | |
| | | } |