001: /*--
002:
003: Copyright (C) 2002-2005 Adrian Price.
004: All rights reserved.
005:
006: Redistribution and use in source and binary forms, with or without
007: modification, are permitted provided that the following conditions
008: are met:
009:
010: 1. Redistributions of source code must retain the above copyright
011: notice, this list of conditions, and the following disclaimer.
012:
013: 2. Redistributions in binary form must reproduce the above copyright
014: notice, this list of conditions, and the disclaimer that follows
015: these conditions in the documentation and/or other materials
016: provided with the distribution.
017:
018: 3. The names "OBE" and "Open Business Engine" must not be used to
019: endorse or promote products derived from this software without prior
020: written permission. For written permission, please contact
021: adrianprice@sourceforge.net.
022:
023: 4. Products derived from this software may not be called "OBE" or
024: "Open Business Engine", nor may "OBE" or "Open Business Engine"
025: appear in their name, without prior written permission from
026: Adrian Price (adrianprice@users.sourceforge.net).
027:
028: THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
029: WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
030: OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
031: DISCLAIMED. IN NO EVENT SHALL THE AUTHOR(S) BE LIABLE FOR ANY DIRECT,
032: INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
033: (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
034: SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
035: HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
036: STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
037: IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
038: POSSIBILITY OF SUCH DAMAGE.
039:
040: For more information on OBE, please see
041: <http://obe.sourceforge.net/>.
042:
043: */
044:
045: package org.obe.server;
046:
047: import org.obe.engine.WorkflowEngine;
048:
049: import java.util.*;
050:
051: /**
052: * The WorkflowServer class is a wrapper around a WorkflowEngine which
053: * provides facilities for persisting process definitions to the file
054: * system as well as invoking certain WorkflowEngine methods.
055: *
056: * @author Anthony Eden
057: */
058:
059: public class WorkflowServer {
060:
061: private WorkflowEngine engine;
062: private Map packageDefinitions;
063:
064: private long lastModified = System.currentTimeMillis();
065:
066: public WorkflowServer(WorkflowEngine engine) {
067: this .engine = engine;
068:
069: packageDefinitions = new HashMap();
070: }
071:
072: /**
073: * Get all package definitions as a Vector of XML documents.
074: *
075: * @return The Vector of package definition documents
076: */
077:
078: public Vector getPackageDefinitions() {
079: Vector definitions = new Vector();
080: Iterator keys = packageDefinitions.keySet().iterator();
081: while (keys.hasNext()) {
082: definitions.add(packageDefinitions.get(keys.next())
083: .toString());
084: }
085:
086: return definitions;
087: }
088:
089: public double getPackageDefinitionsLastModified() {
090: return lastModified;
091: }
092:
093: public void uploadPackage(String packageDefinition) {
094: // save the definition locally
095: // parse the definition
096: // deploy the definition in the workflow engine
097: lastModified = System.currentTimeMillis();
098: }
099:
100: public String downloadPackage(String packageId) {
101: return (String) packageDefinitions.get(packageId);
102: }
103:
104: /**
105: * Execute the given workflow process synchronously. Workflow processes
106: * are identified by a combination of the package ID and the workflow
107: * ID.
108: *
109: * @param packageId The package ID
110: * @param workflowId The workflow process ID
111: * @param parameters Parameters
112: * @return The result data
113: */
114:
115: public Vector executeSynch(String packageId, String workflowId,
116: Vector parameters) throws Exception {
117: return new Vector();
118: }
119:
120: /**
121: * Execute the given workflow process asynchronously. Workflow processes
122: * are identified by a combination of the package ID and the workflow
123: * ID.
124: *
125: * @param packageId The package ID
126: * @param workflowId The workflow process ID
127: * @param parameters Parameters
128: * @return The PID for the workflow process instance
129: */
130:
131: public String executeAsynch(String packageId, String workflowId,
132: Vector parameters) throws Exception {
133: return null;
134: }
135:
136: /**
137: * Convert a List to a Vector. This conversion is necessary because
138: * XML-RPC returns lists as Vector objects.
139: *
140: * @param list The List
141: * @return The Vector
142: */
143:
144: private Vector listToVector(List list) {
145: Vector v = new Vector();
146: Iterator iter = list.iterator();
147: while (iter.hasNext()) {
148: v.add(iter.next());
149: }
150: return v;
151: }
152:
153: }
|