KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > servicemix > beanflow > ExampleStringWorkflow


1 /*
2  * Licensed to the Apache Software Foundation (ASF) under one or more
3  * contributor license agreements. See the NOTICE file distributed with
4  * this work for additional information regarding copyright ownership.
5  * The ASF licenses this file to You under the Apache License, Version 2.0
6  * (the "License"); you may not use this file except in compliance with
7  * the License. You may obtain a copy of the License at
8  *
9  * http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  */
17 package org.apache.servicemix.beanflow;
18
19 import org.apache.commons.logging.Log;
20 import org.apache.commons.logging.LogFactory;
21
22 /**
23  * An example workflow
24  *
25  * @version $Revision: $
26  */
27 // START SNIPPET: workflow
28 public class ExampleStringWorkflow extends Workflow<String JavaDoc> {
29
30     private static final Log log = LogFactory.getLog(ExampleStringWorkflow.class);
31
32     private int loopCount;
33     private long timeout = 1000;
34     private String JavaDoc userEmailAddress;
35
36     public ExampleStringWorkflow() {
37         // lets specify the first step to start at
38 super("startStep");
39     }
40
41     // Workflow steps
42 // -------------------------------------------------------------------------
43
44     // This is the first step of a workflow by default
45 // but you can start at any point by passing in a parameter
46 // to the Workflow constructor
47 public void startStep() {
48         // lets use an explicit goTo() to tell the workflow
49 // which step to go to next; though we can just return Strings
50 addStep("loopStep");
51     }
52
53     // lets use the return value to specify the next step
54 public String JavaDoc loopStep() {
55         if (++loopCount > 3) {
56             return "waitForUserInputStep";
57         }
58         // lets keep looping
59 return "loopStep";
60     }
61
62     public void waitForUserInputStep() {
63         // we are going to park here until a user
64 // enters a valid email address
65 // so lets park the workflow engine
66 }
67
68     public String JavaDoc afterEnteredEmailStep() {
69         // we are going to park here until a user
70 // enters a valid email address
71 log.info("User entered email address: " + userEmailAddress);
72         return "forkStep";
73     }
74
75     public void forkStep() {
76         // lets fork some child flows
77 TimeoutActivity a = new TimeoutActivity();
78         TimeoutActivity b = new TimeoutActivity();
79         TimeoutActivity c = new TimeoutActivity();
80
81         log.info("Forking off processes a, b, c");
82         fork(a, b, c);
83
84         // now lets add some joins
85 joinAll("aCompletedStep", timeout, a);
86         joinAll("abcCompletedStep", timeout, a, b, c);
87     }
88
89     public void aCompletedStep() {
90         log.info("child flow A completed!");
91     }
92
93     public String JavaDoc abcCompletedStep() {
94         log.info("child flows A, B and C completed!");
95
96         // we are completely done now
97 return "stop";
98     }
99
100     // External events
101 // -------------------------------------------------------------------------
102 public void userEntered(String JavaDoc emailAddress) {
103         if (emailAddress != null && emailAddress.indexOf("@") > 0) {
104             this.userEmailAddress = emailAddress;
105
106             log.info("Lets re-start the suspended workflow");
107             addStep("afterEnteredEmailStep");
108         }
109     }
110 }
111 // END SNIPPET: workflow
112
Popular Tags