<dependency>
<groupId>com.xxl-job</groupId>
<artifactId>xxl-job-core</artifactId>
<version>2.1.2</version>
</dependency>
properties
xxl.job.admin.addresses=http://xxl-job-admin:port/xxl-job-admin
@Service
public class MyJobHandler extends IJobHandler {
@Override
public ReturnT<String> execute(String param) throws Exception {
// ...
return ReturnT.SUCCESS;
}
}
@Configuration
public class XxlJobConfig {
@Bean(initMethod = "start", destroyMethod = "destroy")
public XxlJobSpringExecutor xxlJobExecutor() {
XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
xxlJobSpringExecutor.setAdminAddresses("http://xxl-job-admin:port/xxl-job-admin");
xxlJobSpringExecutor.setAppName("xxl-job-executor-sample");
xxlJobSpringExecutor.setAutoStart(true);
xxlJobSpringExecutor.setJobHandlers(Arrays.asList(myJobHandler()));
return xxlJobSpringExecutor;
}
@Bean
public MyJobHandler myJobHandler() {
return new MyJobHandler();
}
}
