|
@@ -1,11 +1,46 @@
|
|
|
package com.xxl.job.executor.core.config;
|
|
|
|
|
|
+import com.xxl.job.core.executor.XxlJobExecutor;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
+import org.springframework.context.annotation.Bean;
|
|
|
+import org.springframework.context.annotation.ComponentScan;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
-import org.springframework.context.annotation.ImportResource;
|
|
|
|
|
|
|
|
|
@Configuration
|
|
|
-@ImportResource("classpath:applicationcontext-xxl-job.xml")
|
|
|
+@ComponentScan(basePackages = "com.xxl.job.executor.service.jobhandler")
|
|
|
public class XxlJobConfig {
|
|
|
+ private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);
|
|
|
+
|
|
|
+
|
|
|
+ @Value("${xxl.job.admin.addresses}")
|
|
|
+ private String addresses;
|
|
|
+
|
|
|
+ @Value("${xxl.job.executor.appname}")
|
|
|
+ private String appname;
|
|
|
+
|
|
|
+ @Value("${xxl.job.executor.ip}")
|
|
|
+ private String ip;
|
|
|
+
|
|
|
+ @Value("${xxl.job.executor.port}")
|
|
|
+ private int port;
|
|
|
+
|
|
|
+ @Value("${xxl.job.executor.logpath}")
|
|
|
+ private String logpath;
|
|
|
+
|
|
|
+
|
|
|
+ @Bean(initMethod = "start", destroyMethod = "destroy")
|
|
|
+ public XxlJobExecutor xxlJobExecutor() {
|
|
|
+ logger.error("------------ xxlJobExecutor -----------");
|
|
|
+ XxlJobExecutor xxlJobExecutor = new XxlJobExecutor();
|
|
|
+ xxlJobExecutor.setIp(ip);
|
|
|
+ xxlJobExecutor.setPort(port);
|
|
|
+ xxlJobExecutor.setAppName(appname);
|
|
|
+ xxlJobExecutor.setAdminAddresses(addresses);
|
|
|
+ xxlJobExecutor.setLogPath(logpath);
|
|
|
+ return xxlJobExecutor;
|
|
|
+ }
|
|
|
|
|
|
}
|