TestDynamicJob.java 902 B

12345678910111213141516171819202122232425262728
  1. package com.xxl.service.job;
  2. import java.util.concurrent.TimeUnit;
  3. import org.quartz.Job;
  4. import org.quartz.JobExecutionContext;
  5. import org.quartz.JobExecutionException;
  6. import org.slf4j.Logger;
  7. import org.slf4j.LoggerFactory;
  8. import com.xxl.quartz.DynamicSchedulerUtil;
  9. public class TestDynamicJob implements Job {
  10. private static Logger logger = LoggerFactory.getLogger(TestDynamicJob.class);
  11. @Override
  12. public void execute(JobExecutionContext context) throws JobExecutionException {
  13. logger.info("xxl-job run: name:{}, group:{}, job_desc:{}",
  14. new Object[]{context.getTrigger().getKey().getName(), context.getTrigger().getKey().getGroup(),
  15. context.getMergedJobDataMap().get(DynamicSchedulerUtil.job_desc)});
  16. try {
  17. TimeUnit.SECONDS.sleep(10);
  18. } catch (InterruptedException e) {
  19. e.printStackTrace();
  20. }
  21. }
  22. }