Quartz Job Scheduling Framework［翻译］第十四章. 工作流中使用 Quartz (第四部分)

 1public class WorkflowJob implements Job {
 2     static Log logger = LogFactory.getLog(WorkflowJob.class);
 3
 4     /**
 5      * Called by the scheduler to execute a workflow
 6      */
 7     public void execute(JobExecutionContext context)
 8               throws JobExecutionException {
 9          JobDataMap jobDataMap = context.getJobDataMap();
10
11          String wfName = jobDataMap.getString("WORKFLOW_NAME");
12          if (wfName != null && wfName.length() > 0) {
13               try {
14                    executeWorkflow(wfName, jobDataMap);
15               } catch (Exception ex) {
16                    logger.error(ex);
17                         throw new
18                              JobExecutionException(ex.getMessage());
19               }
20          } else {
21               logger.error("No Workflow name in JobDataMap");
22          }
23     }
24
25     protected void executeWorkflow(String workflowName,
26          JobDataMap jobDataMap) throws WorkflowException {
27
28          // Create the inputs for the workflow from JobDataMap
29          Map workflowInputs = new HashMap();
30          Iterator iter = jobDataMap.keySet().iterator();
31          while (iter.hasNext()) {
32               String key = (String) iter.next();
33               Object obj = jobDataMap.get(key);
34               workflowInputs.put(key, obj);
35          }
36          // Create and execute the workflow
37          Workflow workflow = new BasicWorkflow("someuser");
38          workflow.setConfiguration(new DefaultConfiguration());
39
40          long workflowId = workflow.initialize(workflowName, 1, workflowInputs);
41
42          workflow.doAction(workflowId, 1, workflowInputs);
43      }
44}

 1public class WorkflowScheduler {
 2     static Log logger = LogFactory.getLog(WorkflowScheduler.class);
 3
 4     public static void main(String[] args) {
 5
 6          try {
 7               // Create and start the Scheduler
 8               Scheduler scheduler =
 9                    StdSchedulerFactory.getDefaultScheduler();
10               scheduler.start();
11
12               JobDetail jobDetail =
13                    new JobDetail("WorkflowJob", null,
14                         WorkflowJob.class);
15               // Store the scan directory and workflow name
16               JobDataMap dataMap = jobDetail.getJobDataMap();
17               dataMap.put("SCAN_DIR", "c:\\quartz-book\\input");
18               dataMap.put("WORKFLOW_NAME", "data-import");
19
20               // Create a simple trigger
21               Trigger trigger =
22                    TriggerUtils.makeSecondlyTrigger(30000, -1);
23               trigger.setName("WorkflowTrigger");
24               trigger.setStartTime(new Date());
25
26               // schedule the job
27               scheduler.scheduleJob(jobDetail, trigger);
28
29          } catch (SchedulerException ex) {
30               logger.error(ex);
31          }
32     }
33}