DemoJobHandler.java 1.0 KB

123456789101112131415161718192021222324252627282930313233343536373839
  1. package com.xxl.job.service.handler;
  2. import java.util.concurrent.TimeUnit;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  5. import org.springframework.stereotype.Service;
  6. import com.xxl.job.client.handler.HandlerRepository;
  7. import com.xxl.job.client.handler.IJobHandler;
  8. /**
  9. * demo job handler
  10. * @author xuxueli 2015-12-19 19:43:36
  11. */
  12. @Service
  13. public class DemoJobHandler extends IJobHandler {
  14. private static transient Logger logger = LoggerFactory.getLogger(DemoJobHandler.class);
  15. public DemoJobHandler() {
  16. HandlerRepository.regist("demoJobHandler", this);
  17. }
  18. @Override
  19. public JobHandleStatus handle(String... params) throws Exception {
  20. logger.info(" ... params:" + params);
  21. for (int i = 0; i < 10; i++) {
  22. TimeUnit.SECONDS.sleep(1);
  23. logger.info("handler run:{}", i);
  24. }
  25. return JobHandleStatus.SUCCESS;
  26. }
  27. public static void main(String[] args) {
  28. System.out.println(DemoJobHandler.class.getName());
  29. System.out.println(DemoJobHandler.class);
  30. }
  31. }