Changeset 1573 for branches/ExampleWorkflow
- Timestamp:
- 05/31/07 15:10:00 (18 months ago)
- Location:
- branches/ExampleWorkflow
- Files:
-
- 3 modified
-
. (modified) (1 prop)
-
src/java/ome/Workflow.java (modified) (2 diffs)
-
src/java/ome/wf1/processdefinition.xml (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
branches/ExampleWorkflow
-
Property
svn:ignore set
to
bin
-
Property
svn:ignore set
to
-
branches/ExampleWorkflow/src/java/ome/Workflow.java
r1572 r1573 1 1 package ome; 2 2 3 import java.io.InputStream; 3 4 import java.util.HashMap; 4 5 import java.util.Map; … … 7 8 import org.jbpm.graph.exe.ProcessInstance; 8 9 9 interface process {10 String xml =11 "<process-definition "+12 "xmlns='' name='wf1'>"+13 " <start-state name='start'>"+14 " <transition name='starting' to='node1'>"+15 " <action name='' class='ome.Log'></action>"+16 " </transition>"+17 " </start-state>"+18 " <node name='node1'>"+19 " <action name='' class='ome.AlgorithmHandler'>" +20 " <wrapperClass>ome.AlgorithmWrapper</wrapperClass>"+21 " <moduleName>Fourier Transform</moduleName>"+22 " <category>Maths.</category>"+23 " <moduleType>OME::Analysis::Handlers::MatlabHandler</moduleType>"+24 " <programID>FourierTransform</programID>"+25 " <featureIterator>ROI</featureIterator>"+26 " <id>urn:lsid:openmicroscopy.org:Module:7503</id>"+27 " </action>"+28 " <transition name='ending' to='end1'>"+29 " <action name='' class='ome.Log'></action>"+30 " </transition>"+31 " </node>"+32 " <end-state name='end1'>"+33 " </end-state>"+34 "</process-definition>";35 }36 37 10 public interface Workflow { 38 long submit(String wf, Map inputs) ;11 long submit(String wf, Map inputs) throws Exception; 39 12 } 40 13 41 14 class client { 42 public static void main(String[] args) {15 public static void main(String[] args) throws Exception { 43 16 Workflow wf = new Wfimpl(); // Remote proxy 44 17 Map inputs = new HashMap(); 45 18 inputs.put("A", "B"); 46 wf.submit( process.xml, inputs);19 wf.submit("/ome/wf1/processdefinition.xml", inputs); 47 20 } 48 21 } 49 22 50 23 class Wfimpl implements Workflow { 51 public long submit(String wf, Map inputs) { 52 ProcessDefinition pd = ProcessDefinition.parseXmlString(wf); 24 public long submit(String wf, Map inputs) throws Exception { 25 InputStream is = Wfimpl.class.getResourceAsStream(wf); 26 ProcessDefinition pd = ProcessDefinition.parseXmlInputStream(is); 53 27 ProcessInstance pi = new ProcessInstance(pd); 54 28 pi.getContextInstance().addVariables(inputs); -
branches/ExampleWorkflow/src/java/ome/wf1/processdefinition.xml
r1572 r1573 1 1 <?xml version="1.0" encoding="UTF-8"?> 2 <!DOCTYPE process-definition SYSTEM "process-definition.dtd"> 2 <!DOCTYPE process-definition PUBLIC 3 "-//jBpm/jBpm Mapping DTD 2.0 beta3//EN" 4 "http://jbpm.org/dtd/processdefinition-2.0.dtd"> 3 5 4 6 <process-definition xmlns='' name='wf1'>
