001: /*--
002:
003: Copyright (C) 2002 Anthony Eden.
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: me@anthonyeden.com.
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: Anthony Eden (me@anthonyeden.com).
027:
028: In addition, I request (but do not require) that you include in the
029: end-user documentation provided with the redistribution and/or in the
030: software itself an acknowledgement equivalent to the following:
031: "This product includes software developed by
032: Anthony Eden (http://www.anthonyeden.com/)."
033:
034: THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
035: WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
036: OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
037: DISCLAIMED. IN NO EVENT SHALL THE AUTHOR(S) BE LIABLE FOR ANY DIRECT,
038: INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
039: (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
040: SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
041: HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
042: STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
043: IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
044: POSSIBILITY OF SUCH DAMAGE.
045:
046: For more information on OBE, please see <http://obe.sourceforge.net/>.
047:
048: */
049:
050: package org.obe.designer;
051:
052: import com.anthonyeden.lib.event.ErrorListener;
053: import com.anthonyeden.lib.event.ErrorListenerSupport;
054: import com.anthonyeden.lib.util.IOUtilities;
055: import java.io.File;
056: import java.io.FileInputStream;
057: import org.apache.commons.logging.Log;
058: import org.apache.commons.logging.LogFactory;
059: import org.obe.xpdl.model.pkg.XPDLPackage;
060: import org.obe.xpdl.parser.dom4j.Dom4JXPDLParser;
061:
062: /**
063: * A threaded class for loading workflow definitions.
064: *
065: * @author Anthony Eden
066: */
067: public class OpenWorkflowThread extends Thread {
068:
069: private static final Log log = LogFactory
070: .getLog(OpenWorkflowThread.class);
071:
072: private File file;
073: private OBEDesigner parent;
074: private ErrorListenerSupport errorListenerSupport;
075:
076: public OpenWorkflowThread(OBEDesigner parent) {
077: this .parent = parent;
078:
079: errorListenerSupport = new ErrorListenerSupport(this );
080: }
081:
082: /**
083: * Load the workflow definition from the given file.
084: *
085: * @param file The file
086: * @throws Exception
087: */
088:
089: public void loadWorkflowDefinition(File file) throws Exception {
090: this .file = file;
091: start();
092: }
093:
094: public void run() {
095: FileInputStream in = null;
096: try {
097: log.info("Parsing workflow definition");
098: parent.setStatus("Opening workflow from "
099: + file.getAbsolutePath());
100: in = new FileInputStream(file);
101: Dom4JXPDLParser parser = new Dom4JXPDLParser();
102: XPDLPackage workflowPackage = parser.parse(in);
103: parent.setWorkflowPackage(workflowPackage);
104: parent.setTitle(file, workflowPackage.getName());
105: } catch (Exception e) {
106: errorListenerSupport.fireError(e);
107: } finally {
108: parent.setStatus("");
109: IOUtilities.close(in);
110: }
111: }
112:
113: /**
114: * Add the specified error listener.
115: *
116: * @param l The ErrorListener
117: */
118: public void addErrorListener(ErrorListener l) {
119: errorListenerSupport.addErrorListener(l);
120: }
121:
122: /**
123: * Remove the specified error listener.
124: *
125: * @param l The ErrorListener
126: */
127: public void removeErrorListener(ErrorListener l) {
128: errorListenerSupport.removeErrorListener(l);
129: }
130: }
|