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

1<osworkflow>
2  <persistence
3    class="com.opensymphony.workflow.spi.memory.MemoryWorkflowStore"/>
4  <factory class="com.opensymphony.workflow.loader.XMLWorkflowFactory">
5    <property name="resource" value="workflows.xml" />
6  </factory>
7</osworkflow>

1<workflows>
2  <workflow
3    name="data-import"
4    type="resource"
5    location="data-import-workflow.xml"/>
6</workflows>

 1<?xml version="1.0" encoding="UTF-8"?>
 2<!DOCTYPE workflow PUBLIC
 3                 "-//OpenSymphony Group//DTD OSWorkflow 2.7//EN"
 4                 "http://www.opensymphony.com/osworkflow/workflow_2_7.dtd">
 5<workflow>
 6    <initial-actions>
 7        <action id="1" name="Start Workflow">
 8            <results>
 9                <unconditional-result old-status="Finished" status="Queued"
10                    step="1" />
11            </results>
12        </action>
13    </initial-actions><br/><br/>
14    <steps>
15        <step id="1" name="Read Files">
16            <actions>
17                <action id="2" name="Get the files" auto="true">
18                    <pre-functions>
19                        <function type="class">
20                            <arg name="class.name">
21                               org.cavaness.quartzbook.chapter14.ReadFileFunction
22                            </arg>
23                        </function>
24                    </pre-functions><br/><br/>
25                    <results>
26                        <unconditional-result old-status="Finished"
27                            status="Underway" step="2" />
28                    </results>
29                </action>
30            </actions>
31        </step><br/><br/>
32        <step id="2" name="Send Email Notification">
33            <actions>
34                <action id="3" name="Get the files" auto="true">
35                    <pre-functions>
36                        <function type="class">
37                            <arg name="class.name">
38                               org.cavaness.quartzbook.chapter14.SendEmailFunction
39                            </arg>
40                        </function>
41                    </pre-functions><br/><br/>
42                    <results>
43                        <unconditional-result old-status="Finished"
44                            status="Underway" step="3" />
45                    </results>
46                </action>
47            </actions>
48        </step><br/><br/>
49        <step id="3" name="finished" />
50    </steps>
51</workflow>

 1public class ReadFileFunction implements FunctionProvider {
 2     static Log logger = LogFactory.getLog(ReadFileFunction.class);
 3
 4     public void execute(Map transientVars, Map args, PropertySet ps)
 5               throws WorkflowException {
 6          logger.info("Entered " + this.getClass().getName());
 7
 8          // Read the files and process the data
 9          String dirName = (String)transientVars.get("SCAN_DIR");
10          if ( dirName == null ) {
11               throw new InvalidInputException( "Scan dir not set" );
12          }
13
14          File dir = new File( dirName );
15          File[] files = dir.listFiles();
16
17          int fileCount = files.length;
18          ps.setInt( "FILE_COUNT", fileCount );
19     }
20}

 1public class SendEmailFunction implements FunctionProvider {
 2     static Log logger = LogFactory.getLog(SendEmailFunction.class);
 3
 4     public void execute(Map transientVars, Map args, PropertySet ps)
 5               throws WorkflowException {
 6          logger.info("Entered " + this.getClass().getName());
 7
 8          int fileCount = ps.getInt("FILE_COUNT");
 9          logger.info( "File count " + fileCount );
10
11          // Email creation code not shown
12     }
13}