1 17 18 package org.quartz.examples.example13; 19 20 import java.util.Date ; 21 22 import org.apache.commons.logging.Log; 23 import org.apache.commons.logging.LogFactory; 24 import org.quartz.Job; 25 import org.quartz.JobDataMap; 26 import org.quartz.JobExecutionContext; 27 import org.quartz.JobExecutionException; 28 29 36 public class SimpleRecoveryJob implements Job { 37 38 private static Log _log = LogFactory.getLog(SimpleRecoveryJob.class); 39 40 private static final String COUNT = "count"; 41 42 46 public SimpleRecoveryJob() { 47 } 48 49 59 public void execute(JobExecutionContext context) 60 throws JobExecutionException { 61 62 String jobName = context.getJobDetail().getFullName(); 63 64 if (context.isRecovering()) { 66 _log.info("SimpleRecoveryJob: " + jobName + " RECOVERING at " + new Date ()); 67 } else { 68 _log.info("SimpleRecoveryJob: " + jobName + " starting at " + new Date ()); 69 } 70 71 long delay = 10L * 1000L; 73 try { 74 Thread.sleep(delay); 75 } catch (Exception e) { 76 } 77 78 JobDataMap data = context.getJobDetail().getJobDataMap(); 79 int count; 80 if (data.containsKey(COUNT)) { 81 count = data.getInt(COUNT); 82 } else { 83 count = 0; 84 } 85 count++; 86 data.put(COUNT, count); 87 88 _log.info("SimpleRecoveryJob: " + jobName + 89 " done at " + new Date () + 90 "\n Execution #" + count); 91 92 } 93 94 95 96 } | Popular Tags |