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.server.xmlrpc;
051:
052: import org.apache.commons.logging.Log;
053: import org.apache.commons.logging.LogFactory;
054: import org.apache.xmlrpc.WebServer;
055: import org.obe.server.WorkflowServer;
056:
057: public class OBEXmlRpcServer {
058: public static final int DEFAULT_PORT = 8988;
059: public static final int DEFAULT_ADMIN_PORT = 8990;
060:
061: public static final String STATUS_RUNNING = "Running";
062: public static final String STATUS_STOPPING = "Stopping";
063: public static final String STATUS_STARTING = "Starting";
064: public static final String STATUS_STOPPED = "Stopped";
065: public static final String STATUS_SHUTTING_DOWN = "Shutting Down";
066:
067: private static final Log log = LogFactory
068: .getLog(OBEXmlRpcServer.class);
069:
070: private WebServer webServer;
071: private WebServer adminServer;
072:
073: private WorkflowServer server;
074: private String status;
075: private int port;
076:
077: public OBEXmlRpcServer(WorkflowServer server) throws Exception {
078: this (server, DEFAULT_ADMIN_PORT);
079: }
080:
081: public OBEXmlRpcServer(WorkflowServer server, int adminPort)
082: throws Exception {
083: this .server = server;
084: log.info("Starting admin server on " + adminPort);
085: adminServer = new WebServer(adminPort);
086: adminServer.addHandler("system", this );
087: log.info("Admin server running");
088: }
089:
090: public String getStatus() {
091: return status;
092: }
093:
094: public int getPort() {
095: return port;
096: }
097:
098: public String startServer() {
099: return startServer(DEFAULT_PORT);
100: }
101:
102: public String startServer(int port) {
103: if (webServer == null) {
104: try {
105:
106: setStatus(STATUS_STARTING);
107: log.info("Starting server on port " + port);
108: webServer = new WebServer(port);
109:
110: //webServer.addHandler("obe",
111: // new EventXmlRpcHandler(runtimeContext));
112: //log.info("Added 'obe' object");
113:
114: webServer.addHandler("system", this );
115: log.info("Added 'system' object");
116:
117: webServer.addHandler("server", server);
118: log.info("Added 'server' object");
119:
120: log.info("Server running");
121:
122: setStatus(STATUS_RUNNING);
123: setPort(port);
124:
125: return "OK";
126: } catch (Exception e) {
127: e.printStackTrace();
128: return "FAILED: Startup error - " + e.getMessage();
129: }
130: } else {
131: return "FAILED: Server already running";
132: }
133: }
134:
135: public String stopServer() {
136: if (webServer != null) {
137: setStatus(STATUS_STOPPING);
138: log.info("Stopping server");
139: webServer.shutdown();
140: log.info("Server stopped");
141: setStatus(STATUS_STOPPED);
142: webServer = null;
143: return "OK";
144: } else {
145: return "FAILED: Server not running";
146: }
147: }
148:
149: public String shutdownServer() {
150: log.info("Shutting down server");
151: stopServer();
152: setStatus(STATUS_SHUTTING_DOWN);
153: adminServer.shutdown();
154: Thread t = new Thread(new Runnable() {
155: public void run() {
156: log.info("Shutting down in 10 seconds");
157: try {
158: Thread.sleep(10000);
159: } catch (InterruptedException e) {
160:
161: }
162: log.info("Shutting down");
163: System.exit(0);
164: }
165: }, "ShutdownThread");
166: t.start();
167: return "OK";
168: }
169:
170: private void setStatus(String status) {
171: this .status = status;
172: }
173:
174: private void setPort(int port) {
175: this.port = port;
176: }
177:
178: }
|