Forráskód Böngészése

优化侦听启动bug

java110 5 éve%!(EXTRA string=óta)
szülő
commit
31ac63cdca

+ 2 - 1
service-job/src/main/java/com/java110/job/JobServiceApplication.java

@@ -2,6 +2,7 @@ package com.java110.job;
 
 import com.java110.core.annotation.Java110ListenerDiscovery;
 import com.java110.core.event.center.DataFlowEventPublishing;
+import com.java110.core.event.service.BusinessServiceDataFlowEventPublishing;
 import com.java110.service.init.ServiceStartInit;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -28,7 +29,7 @@ import java.nio.charset.Charset;
         excludeName = {"com.java110.core.smo.jobservice"}
 )
 @EnableDiscoveryClient
-@Java110ListenerDiscovery(listenerPublishClass = DataFlowEventPublishing.class,
+@Java110ListenerDiscovery(listenerPublishClass = BusinessServiceDataFlowEventPublishing.class,
         basePackages = {"com.java110.job.listener"})
 @EnableFeignClients(basePackages = {"com.java110.core.smo.community",
         "com.java110.core.smo.fee",