Modified: ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java (original)
+++ ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java Tue Feb 17 22:15:22 2009
@@ -1,336 +1,336 @@
-package org.apache.ode.axis2.service;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
-import java.io.Writer;
-import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.List;
-
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.xml.namespace.QName;
-
-import org.apache.axis2.description.AxisOperation;
-import org.apache.axis2.description.AxisService;
-import org.apache.axis2.engine.AxisConfiguration;
-import org.apache.commons.lang.StringUtils;
-import org.apache.ode.store.ProcessStoreImpl;
-import org.apache.ode.utils.fs.FileUtils;
-
-/**
- * handles a set of URLs all starting with /deployment to publish all files in
- * deployed bundles, services and processes.
- */
-public class DeploymentBrowser {
-
- private ProcessStoreImpl _store;
- private AxisConfiguration _config;
- private File _appRoot;
-
- public DeploymentBrowser(ProcessStoreImpl store, AxisConfiguration config, File appRoot) {
- _store = store;
- _config = config;
- _appRoot = appRoot;
- }
-
- // A fake filter, directly called from the ODEAxisServlet
- public boolean doFilter(final HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
- final String requestURI = request.getRequestURI();
- final int deplUri = requestURI.indexOf("/deployment");
- if (deplUri > 0) {
- final String root = request.getScheme() + "://" + request.getServerName() +
- ":" + request.getServerPort() + requestURI.substring(0, deplUri);
- int offset = requestURI.length() > (deplUri + 11) ? 1 : 0;
- final String[] segments = requestURI.substring(deplUri + 11 + offset).split("/");
- if (segments.length == 0 || segments[0].length() == 0) {
- renderHtml(response, "ODE Deployment Browser", new DocBody() {
- public void render(Writer out) throws IOException {
- out.write("<p><a href=\"bundles/\">Deployed Bundles</a></p>");
- out.write("<p><a href=\"services/\">Process Services</a></p>");
- out.write("<p><a href=\"processes/\">Process Definitions</a></p>");
- }
- });
- } else if (segments.length > 0) {
- if ("services".equals(segments[0])) {
- if (segments.length == 1) {
- renderHtml(response, "Services Implemented by Your Processes", new DocBody() {
- public void render(Writer out) throws IOException {
- for (Object serviceName : _config.getServices().keySet())
- if (!"Version".equals(serviceName)) {
- AxisService service = _config.getService(serviceName.toString());
-
- // The service can be one of the dynamically registered ODE services, a process
- // service or an unknown service deployed in the same Axis2 instance.
- String url = null;
- if ("DeploymentService".equals(service.getName())
- || "InstanceManagement".equals(service.getName())
- || "ProcessManagement".equals(service.getName()))
- url = service.getName();
- else if (service.getFileName() != null) {
- String relative = bundleUrlFor(service.getFileName().getFile());
- if (relative != null) url = root + relative;
- else url = root + "/services/" + service.getName() + "?wsdl";
- }
-
- out.write("<p><a href=\"" + url + "\">" + serviceName + "</a></p>");
-
- out.write("<ul><li>Endpoint: " + (root + "/processes/" + serviceName) + "</li>");
- Iterator iter = service.getOperations();
- ArrayList<String> ops = new ArrayList<String>();
- while (iter.hasNext()) ops.add(((AxisOperation)iter.next()).getName().getLocalPart());
- out.write("<li>Operations: " + StringUtils.join(ops.iterator(), ", ") + "</li></ul>");
- }
- }
- });
- } else {
- final String serviceName = requestURI.substring(deplUri + 12 + 9);
- final AxisService axisService = _config.getService(serviceName);
- if (axisService != null) {
- renderXml(response, new DocBody() {
- public void render(Writer out) throws IOException {
- if ("InstanceManagement".equals(serviceName) || "ProcessManagement".equals(serviceName))
- write(out, new File(_appRoot, "pmapi.wsdl").getPath());
- else if (requestURI.indexOf("pmapi.xsd") > 0)
- write(out, new File(_appRoot, "pmapi.xsd").getPath());
- else if ("DeploymentService".equals(serviceName))
- write(out, new File(_appRoot, "deploy.wsdl").getPath());
- else
- write(out, axisService.getFileName().getFile());
- }
- });
- } else {
- renderHtml(response, "Service Not Found", new DocBody() {
- public void render(Writer out) throws IOException {
- out.write("<p>Couldn't find service " + serviceName + "</p>");
- }
- });
- }
- }
- } else if ("processes".equals(segments[0])) {
- if (segments.length == 1) {
- renderHtml(response, "Deployed Processes", new DocBody() {
- public void render(Writer out) throws IOException {
- for (QName process :_store.getProcesses()) {
- String url = root + bundleUrlFor(_store.getProcessConfiguration(process).getBpelDocument());
- String[] nameVer = process.getLocalPart().split("-");
- out.write("<p><a href=\"" + url + "\">" + nameVer[0] + "</a> (v" + nameVer[1] + ")");
- out.write(" - " + process.getNamespaceURI() + "</p>");
- }
- }
- });
- }
- } else if ("bundles".equals(segments[0])) {
- if (segments.length == 1) {
- renderHtml(response, "Deployment Bundles", new DocBody() {
- public void render(Writer out) throws IOException {
- for (String bundle : _store.getPackages())
- out.write("<p><a href=\"" + bundle + "\">" + bundle + "</a></p>");
- }
- });
- } else if (segments.length == 2) {
- renderHtml(response, "Files in Bundle " + segments[1], new DocBody() {
- public void render(Writer out) throws IOException {
- List<QName> processes = _store.listProcesses(segments[1]);
- if (processes != null) {
- List<File> files = _store.getProcessConfiguration(processes.get(0)).getFiles();
- for (File file : files) {
- String relativePath = file.getPath().substring(file.getPath()
- .indexOf("processes")+10).replaceAll("\\\\", "/");
- out.write("<p><a href=\"" + relativePath + "\">" + relativePath + "</a></p>");
- }
- } else {
- out.write("<p>Couldn't find bundle " + segments[2] + "</p>");
- }
- }
- });
- } else if (segments.length > 2) {
- List<QName> processes = _store.listProcesses(segments[1]);
- if (processes != null) {
- List<File> files = _store.getProcessConfiguration(processes.get(0)).getFiles();
- for (final File file : files) {
- String relativePath = requestURI.substring(deplUri + 12 + 9 + segments[1].length());
- if (file.getPath().endsWith(relativePath)) {
- renderXml(response, new DocBody() {
- public void render(Writer out) throws IOException {
- write(out, file.getPath());
- }
- });
- return true;
- }
- }
- } else {
- renderHtml(response, "No Bundle Found", new DocBody() {
- public void render(Writer out) throws IOException {
- out.write("<p>Couldn't find bundle " + segments[2] + "</p>");
- }
- });
- }
- }
- } else if("getBundleDocs".equals(segments[0])){
- if(segments.length == 1){
- renderXml(response, new DocBody(){
- public void render(Writer out) throws IOException{
- out.write("<getBundleDocsResponse>");
- out.write("<error>Not enough args..</error>");
- out.write("</getBundleDocsResponse>");
- }
- });
- }else if (segments.length == 2){
- final String bundleName = segments[1];
- final List<QName> processes = _store.listProcesses(bundleName);
- if(processes != null){
- renderXml(response, new DocBody(){
- public void render(Writer out) throws IOException{
- out.write("<getBundleDocsResponse><name>"+ bundleName +"</name>");
- //final List<File> files = _store.getProcessConfiguration(processes.get(0)).getFiles();
- //final String pid = _store.getProcessConfiguration(processes.get(0)).getProcessId().toString();
-
- for(final QName process: processes){
- List<File> files = _store.getProcessConfiguration(process).getFiles();
- String pid = _store.getProcessConfiguration(process).getProcessId().toString();
- out.write("<process><pid>"+pid+"</pid>");
- for (final File file : files){
- if(file.getPath().endsWith(".wsdl")){
- String relativePath = file.getPath().substring(_store.getDeployDir().getCanonicalPath().length() + 1);
- out.write("<wsdl>"+ relativePath + "</wsdl>");
- }
- if(file.getPath().endsWith(".bpel")){
- String relativePath = file.getPath().substring(_store.getDeployDir().getCanonicalPath().length() + 1);
- out.write("<bpel>"+ relativePath + "</bpel>");
- }
-
- }
- out.write("</process>");
- }
- out.write("</getBundleDocsResponse>");
- }
- });
-
- }
- }
- }else if("getProcessDefinition".equals(segments[0])){
- if(segments.length == 1){
- renderXml(response, new DocBody(){
- public void render(Writer out) throws IOException{
- out.write("<getProcessDefinitionResponse>");
- out.write("<error>Not enough args..</error>");
- out.write("</getProcessDefinitionResponse>");
- }
- });
- }else if (segments.length == 2){
- String processName = segments[1];
- for (QName process :_store.getProcesses()) {
- String[] nameVer = process.getLocalPart().split("-");
- if(processName.equals(nameVer[0])){
- final String url = root + bundleUrlFor(_store.getProcessConfiguration(process).getBpelDocument());
- renderXml(response, new DocBody(){
- public void render(Writer out) throws IOException{
- out.write("<getProcessDefinition>");
- out.write("<url>"+ url +"</url>");
- out.write("</getProcessDefinition>");
- }
- });
- }
- }
- }
- }
- }
- return true;
- }
- return false;
- }
-
- static interface DocBody {
- void render(Writer out) throws IOException;
- }
- private void renderHtml(HttpServletResponse response, String title, DocBody docBody) throws IOException {
- response.setContentType("text/html");
-
- Writer out = response.getWriter();
- out.write("<html><header><style type=\"text/css\">" + CSS + "</style></header><body>\n");
- out.write("<h2>" + title + "</h2><p/>\n");
- docBody.render(out);
- out.write("</body></html>");
- }
- private void renderXml(HttpServletResponse response, DocBody docBody) throws IOException {
- response.setContentType("text/xml");
- response.setCharacterEncoding("UTF-8");
-
- Writer out = response.getWriter();
- docBody.render(out);
- }
-
- private void write(Writer out, String filePath) throws IOException {
- BufferedReader wsdlReader = new BufferedReader(new FileReader(filePath));
- String line;
- while((line = wsdlReader.readLine()) != null) out.write(line + "\n");
- wsdlReader.close();
- }
-
- private String bundleUrlFor(String docFile) {
- if (docFile.indexOf("processes") >= 0) docFile = docFile.substring(docFile.indexOf("processes")+10);
- List<File> files = FileUtils.listFilesRecursively(_store.getDeployDir(), null);
- for (final File bundleFile : files) {
- if (bundleFile.getPath().replaceAll("\\\\", "/").endsWith(docFile))
- return "/deployment/bundles/" + bundleFile.getPath()
- .substring(_store.getDeployDir().getPath().length() + 1).replaceAll("\\\\", "/");
- }
- return null;
- }
-
- private static final String CSS =
- "body {\n" +
- " font: 75% Verdana, Helvetica, Arial, sans-serif;\n" +
- " background: White;\n" +
- " color: Black;\n" +
- " margin: 1em;\n" +
- " padding: 1em;\n" +
- "}\n" +
- "\n" +
- "h1, h2, h3, h4, h5, h6 {\n" +
- " color: Black;\n" +
- " clear: left;\n" +
- " font: 100% Verdana, Helvetica, Arial, sans-serif;\n" +
- " margin: 0;\n" +
- " padding-left: 0.5em;\n" +
- "} \n" +
- "\n" +
- "h1 {\n" +
- " font-size: 150%;\n" +
- " border-bottom: none;\n" +
- " text-align: right;\n" +
- " border-bottom: 1px solid Gray;\n" +
- "}\n" +
- " \n" +
- "h2 {\n" +
- " font-size: 130%;\n" +
- " border-bottom: 1px solid Gray;\n" +
- "}\n" +
- "\n" +
- "h3 {\n" +
- " font-size: 120%;\n" +
- " padding-left: 1.0em;\n" +
- " border-bottom: 1px solid Gray;\n" +
- "}\n" +
- "\n" +
- "h4 {\n" +
- " font-size: 110%;\n" +
- " padding-left: 1.5em;\n" +
- " border-bottom: 1px solid Gray;\n" +
- "}\n" +
- "\n" +
- "p {\n" +
- " text-align: justify;\n" +
- " line-height: 1.5em;\n" +
- " padding-left: 1.5em;\n" +
- "}\n" +
- "\n" +
- "a {\n" +
- " text-decoration: underline;\n" +
- " color: Black;\n" +
- "}";
-}
+package org.apache.ode.axis2.service;
+
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileReader;
+import java.io.IOException;
+import java.io.Writer;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.xml.namespace.QName;
+
+import org.apache.axis2.description.AxisOperation;
+import org.apache.axis2.description.AxisService;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.commons.lang.StringUtils;
+import org.apache.ode.store.ProcessStoreImpl;
+import org.apache.ode.utils.fs.FileUtils;
+
+/**
+ * handles a set of URLs all starting with /deployment to publish all files in
+ * deployed bundles, services and processes.
+ */
+public class DeploymentBrowser {
+
+ private ProcessStoreImpl _store;
+ private AxisConfiguration _config;
+ private File _appRoot;
+
+ public DeploymentBrowser(ProcessStoreImpl store, AxisConfiguration config, File appRoot) {
+ _store = store;
+ _config = config;
+ _appRoot = appRoot;
+ }
+
+ // A fake filter, directly called from the ODEAxisServlet
+ public boolean doFilter(final HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+ final String requestURI = request.getRequestURI();
+ final int deplUri = requestURI.indexOf("/deployment");
+ if (deplUri > 0) {
+ final String root = request.getScheme() + "://" + request.getServerName() +
+ ":" + request.getServerPort() + requestURI.substring(0, deplUri);
+ int offset = requestURI.length() > (deplUri + 11) ? 1 : 0;
+ final String[] segments = requestURI.substring(deplUri + 11 + offset).split("/");
+ if (segments.length == 0 || segments[0].length() == 0) {
+ renderHtml(response, "ODE Deployment Browser", new DocBody() {
+ public void render(Writer out) throws IOException {
+ out.write("<p><a href=\"bundles/\">Deployed Bundles</a></p>");
+ out.write("<p><a href=\"services/\">Process Services</a></p>");
+ out.write("<p><a href=\"processes/\">Process Definitions</a></p>");
+ }
+ });
+ } else if (segments.length > 0) {
+ if ("services".equals(segments[0])) {
+ if (segments.length == 1) {
+ renderHtml(response, "Services Implemented by Your Processes", new DocBody() {
+ public void render(Writer out) throws IOException {
+ for (Object serviceName : _config.getServices().keySet())
+ if (!"Version".equals(serviceName)) {
+ AxisService service = _config.getService(serviceName.toString());
+
+ // The service can be one of the dynamically registered ODE services, a process
+ // service or an unknown service deployed in the same Axis2 instance.
+ String url = null;
+ if ("DeploymentService".equals(service.getName())
+ || "InstanceManagement".equals(service.getName())
+ || "ProcessManagement".equals(service.getName()))
+ url = service.getName();
+ else if (service.getFileName() != null) {
+ String relative = bundleUrlFor(service.getFileName().getFile());
+ if (relative != null) url = root + relative;
+ else url = root + "/services/" + service.getName() + "?wsdl";
+ }
+
+ out.write("<p><a href=\"" + url + "\">" + serviceName + "</a></p>");
+
+ out.write("<ul><li>Endpoint: " + (root + "/processes/" + serviceName) + "</li>");
+ Iterator iter = service.getOperations();
+ ArrayList<String> ops = new ArrayList<String>();
+ while (iter.hasNext()) ops.add(((AxisOperation)iter.next()).getName().getLocalPart());
+ out.write("<li>Operations: " + StringUtils.join(ops.iterator(), ", ") + "</li></ul>");
+ }
+ }
+ });
+ } else {
+ final String serviceName = requestURI.substring(deplUri + 12 + 9);
+ final AxisService axisService = _config.getService(serviceName);
+ if (axisService != null) {
+ renderXml(response, new DocBody() {
+ public void render(Writer out) throws IOException {
+ if ("InstanceManagement".equals(serviceName) || "ProcessManagement".equals(serviceName))
+ write(out, new File(_appRoot, "pmapi.wsdl").getPath());
+ else if (requestURI.indexOf("pmapi.xsd") > 0)
+ write(out, new File(_appRoot, "pmapi.xsd").getPath());
+ else if ("DeploymentService".equals(serviceName))
+ write(out, new File(_appRoot, "deploy.wsdl").getPath());
+ else
+ write(out, axisService.getFileName().getFile());
+ }
+ });
+ } else {
+ renderHtml(response, "Service Not Found", new DocBody() {
+ public void render(Writer out) throws IOException {
+ out.write("<p>Couldn't find service " + serviceName + "</p>");
+ }
+ });
+ }
+ }
+ } else if ("processes".equals(segments[0])) {
+ if (segments.length == 1) {
+ renderHtml(response, "Deployed Processes", new DocBody() {
+ public void render(Writer out) throws IOException {
+ for (QName process :_store.getProcesses()) {
+ String url = root + bundleUrlFor(_store.getProcessConfiguration(process).getBpelDocument());
+ String[] nameVer = process.getLocalPart().split("-");
+ out.write("<p><a href=\"" + url + "\">" + nameVer[0] + "</a> (v" + nameVer[1] + ")");
+ out.write(" - " + process.getNamespaceURI() + "</p>");
+ }
+ }
+ });
+ }
+ } else if ("bundles".equals(segments[0])) {
+ if (segments.length == 1) {
+ renderHtml(response, "Deployment Bundles", new DocBody() {
+ public void render(Writer out) throws IOException {
+ for (String bundle : _store.getPackages())
+ out.write("<p><a href=\"" + bundle + "\">" + bundle + "</a></p>");
+ }
+ });
+ } else if (segments.length == 2) {
+ renderHtml(response, "Files in Bundle " + segments[1], new DocBody() {
+ public void render(Writer out) throws IOException {
+ List<QName> processes = _store.listProcesses(segments[1]);
+ if (processes != null) {
+ List<File> files = _store.getProcessConfiguration(processes.get(0)).getFiles();
+ for (File file : files) {
+ String relativePath = file.getPath().substring(file.getPath()
+ .indexOf("processes")+10).replaceAll("\\\\", "/");
+ out.write("<p><a href=\"" + relativePath + "\">" + relativePath + "</a></p>");
+ }
+ } else {
+ out.write("<p>Couldn't find bundle " + segments[2] + "</p>");
+ }
+ }
+ });
+ } else if (segments.length > 2) {
+ List<QName> processes = _store.listProcesses(segments[1]);
+ if (processes != null) {
+ List<File> files = _store.getProcessConfiguration(processes.get(0)).getFiles();
+ for (final File file : files) {
+ String relativePath = requestURI.substring(deplUri + 12 + 9 + segments[1].length());
+ if (file.getPath().endsWith(relativePath)) {
+ renderXml(response, new DocBody() {
+ public void render(Writer out) throws IOException {
+ write(out, file.getPath());
+ }
+ });
+ return true;
+ }
+ }
+ } else {
+ renderHtml(response, "No Bundle Found", new DocBody() {
+ public void render(Writer out) throws IOException {
+ out.write("<p>Couldn't find bundle " + segments[2] + "</p>");
+ }
+ });
+ }
+ }
+ } else if("getBundleDocs".equals(segments[0])){
+ if(segments.length == 1){
+ renderXml(response, new DocBody(){
+ public void render(Writer out) throws IOException{
+ out.write("<getBundleDocsResponse>");
+ out.write("<error>Not enough args..</error>");
+ out.write("</getBundleDocsResponse>");
+ }
+ });
+ }else if (segments.length == 2){
+ final String bundleName = segments[1];
+ final List<QName> processes = _store.listProcesses(bundleName);
+ if(processes != null){
+ renderXml(response, new DocBody(){
+ public void render(Writer out) throws IOException{
+ out.write("<getBundleDocsResponse><name>"+ bundleName +"</name>");
+ //final List<File> files = _store.getProcessConfiguration(processes.get(0)).getFiles();
+ //final String pid = _store.getProcessConfiguration(processes.get(0)).getProcessId().toString();
+
+ for(final QName process: processes){
+ List<File> files = _store.getProcessConfiguration(process).getFiles();
+ String pid = _store.getProcessConfiguration(process).getProcessId().toString();
+ out.write("<process><pid>"+pid+"</pid>");
+ for (final File file : files){
+ if(file.getPath().endsWith(".wsdl")){
+ String relativePath = file.getPath().substring(_store.getDeployDir().getCanonicalPath().length() + 1);
+ out.write("<wsdl>"+ relativePath + "</wsdl>");
+ }
+ if(file.getPath().endsWith(".bpel")){
+ String relativePath = file.getPath().substring(_store.getDeployDir().getCanonicalPath().length() + 1);
+ out.write("<bpel>"+ relativePath + "</bpel>");
+ }
+
+ }
+ out.write("</process>");
+ }
+ out.write("</getBundleDocsResponse>");
+ }
+ });
+
+ }
+ }
+ }else if("getProcessDefinition".equals(segments[0])){
+ if(segments.length == 1){
+ renderXml(response, new DocBody(){
+ public void render(Writer out) throws IOException{
+ out.write("<getProcessDefinitionResponse>");
+ out.write("<error>Not enough args..</error>");
+ out.write("</getProcessDefinitionResponse>");
+ }
+ });
+ }else if (segments.length == 2){
+ String processName = segments[1];
+ for (QName process :_store.getProcesses()) {
+ String[] nameVer = process.getLocalPart().split("-");
+ if(processName.equals(nameVer[0])){
+ final String url = root + bundleUrlFor(_store.getProcessConfiguration(process).getBpelDocument());
+ renderXml(response, new DocBody(){
+ public void render(Writer out) throws IOException{
+ out.write("<getProcessDefinition>");
+ out.write("<url>"+ url +"</url>");
+ out.write("</getProcessDefinition>");
+ }
+ });
+ }
+ }
+ }
+ }
+ }
+ return true;
+ }
+ return false;
+ }
+
+ static interface DocBody {
+ void render(Writer out) throws IOException;
+ }
+ private void renderHtml(HttpServletResponse response, String title, DocBody docBody) throws IOException {
+ response.setContentType("text/html");
+
+ Writer out = response.getWriter();
+ out.write("<html><header><style type=\"text/css\">" + CSS + "</style></header><body>\n");
+ out.write("<h2>" + title + "</h2><p/>\n");
+ docBody.render(out);
+ out.write("</body></html>");
+ }
+ private void renderXml(HttpServletResponse response, DocBody docBody) throws IOException {
+ response.setContentType("text/xml");
+ response.setCharacterEncoding("UTF-8");
+
+ Writer out = response.getWriter();
+ docBody.render(out);
+ }
+
+ private void write(Writer out, String filePath) throws IOException {
+ BufferedReader wsdlReader = new BufferedReader(new FileReader(filePath));
+ String line;
+ while((line = wsdlReader.readLine()) != null) out.write(line + "\n");
+ wsdlReader.close();
+ }
+
+ private String bundleUrlFor(String docFile) {
+ if (docFile.indexOf("processes") >= 0) docFile = docFile.substring(docFile.indexOf("processes")+10);
+ List<File> files = FileUtils.listFilesRecursively(_store.getDeployDir(), null);
+ for (final File bundleFile : files) {
+ if (bundleFile.getPath().replaceAll("\\\\", "/").endsWith(docFile))
+ return "/deployment/bundles/" + bundleFile.getPath()
+ .substring(_store.getDeployDir().getPath().length() + 1).replaceAll("\\\\", "/");
+ }
+ return null;
+ }
+
+ private static final String CSS =
+ "body {\n" +
+ " font: 75% Verdana, Helvetica, Arial, sans-serif;\n" +
+ " background: White;\n" +
+ " color: Black;\n" +
+ " margin: 1em;\n" +
+ " padding: 1em;\n" +
+ "}\n" +
+ "\n" +
+ "h1, h2, h3, h4, h5, h6 {\n" +
+ " color: Black;\n" +
+ " clear: left;\n" +
+ " font: 100% Verdana, Helvetica, Arial, sans-serif;\n" +
+ " margin: 0;\n" +
+ " padding-left: 0.5em;\n" +
+ "} \n" +
+ "\n" +
+ "h1 {\n" +
+ " font-size: 150%;\n" +
+ " border-bottom: none;\n" +
+ " text-align: right;\n" +
+ " border-bottom: 1px solid Gray;\n" +
+ "}\n" +
+ " \n" +
+ "h2 {\n" +
+ " font-size: 130%;\n" +
+ " border-bottom: 1px solid Gray;\n" +
+ "}\n" +
+ "\n" +
+ "h3 {\n" +
+ " font-size: 120%;\n" +
+ " padding-left: 1.0em;\n" +
+ " border-bottom: 1px solid Gray;\n" +
+ "}\n" +
+ "\n" +
+ "h4 {\n" +
+ " font-size: 110%;\n" +
+ " padding-left: 1.5em;\n" +
+ " border-bottom: 1px solid Gray;\n" +
+ "}\n" +
+ "\n" +
+ "p {\n" +
+ " text-align: justify;\n" +
+ " line-height: 1.5em;\n" +
+ " padding-left: 1.5em;\n" +
+ "}\n" +
+ "\n" +
+ "a {\n" +
+ " text-decoration: underline;\n" +
+ " color: Black;\n" +
+ "}";
+}
Modified: ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java (original)
+++ ode/trunk/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java Tue Feb 17 22:15:22 2009
@@ -153,15 +153,15 @@
OMElement response = factory.createOMElement("response", null);
if (__log.isDebugEnabled()) __log.debug("Deployed package: "+dest.getName());
- OMElement d = factory.createOMElement("name", null);
- d.setText(dest.getName());
- response.addChild(d);
-
- for (QName pid : deployed) {
- if (__log.isDebugEnabled()) __log.debug("Deployed PID: "+pid);
- d = factory.createOMElement("id", null);
- d.setText(pid);
- response.addChild(d);
+ OMElement d = factory.createOMElement("name", null);
+ d.setText(dest.getName());
+ response.addChild(d);
+
+ for (QName pid : deployed) {
+ if (__log.isDebugEnabled()) __log.debug("Deployed PID: "+pid);
+ d = factory.createOMElement("id", null);
+ d.setText(pid);
+ response.addChild(d);
}
sendResponse(factory, messageContext, "deployResponse", response);
} finally {
@@ -217,7 +217,7 @@
OMElement qnamePart = messageContext.getEnvelope().getBody().getFirstElement().getFirstElement();
ProcessConf process = _store.getProcessConfiguration(OMUtils.getTextAsQName(qnamePart));
if (process == null) {
- throw new OdeFault("Could not find process: " + qnamePart.getTextAsQName());
+ throw new OdeFault("Could not find process: " + qnamePart.getTextAsQName());
}
String packageName = _store.getProcessConfiguration(OMUtils.getTextAsQName(qnamePart)).getPackage();
OMElement response = factory.createOMElement("packageName", null);
Modified: ode/trunk/axis2/src/main/java/org/apache/ode/axis2/soapbinding/SoapMessageConverter.java
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/soapbinding/SoapMessageConverter.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/axis2/src/main/java/org/apache/ode/axis2/soapbinding/SoapMessageConverter.java (original)
+++ ode/trunk/axis2/src/main/java/org/apache/ode/axis2/soapbinding/SoapMessageConverter.java Tue Feb 17 22:15:22 2009
@@ -123,11 +123,11 @@
_isRPC = style != null && style.equals("rpc");
if (_soapBinding.getElementType().getNamespaceURI().equals(Constants.URI_WSDL11_SOAP)) {
- _soapFactory = OMAbstractFactory.getSOAP11Factory();
+ _soapFactory = OMAbstractFactory.getSOAP11Factory();
} else if (_soapBinding.getElementType().getNamespaceURI().equals(Constants.URI_WSDL12_SOAP)) {
- _soapFactory = OMAbstractFactory.getSOAP12Factory();
+ _soapFactory = OMAbstractFactory.getSOAP12Factory();
} else {
- throw new IllegalStateException("Unsupported SOAP binding: " + _soapBinding.getElementType());
+ throw new IllegalStateException("Unsupported SOAP binding: " + _soapBinding.getElementType());
}
}
@@ -208,7 +208,7 @@
for (Node headerNode : headers.values())
if (headerNode.getNodeType() == Node.ELEMENT_NODE) {
if (soaphdr.getFirstChildWithName(new QName(headerNode.getNamespaceURI(), headerNode.getLocalName())) == null) {
- OMElement omHeaderNode = OMUtils.toOM((Element) headerNode, _soapFactory);
+ OMElement omHeaderNode = OMUtils.toOM((Element) headerNode, _soapFactory);
SOAPHeaderBlock hb = soaphdr.addHeaderBlock(omHeaderNode.getLocalName(), omHeaderNode.getNamespace());
// add child elements
Modified: ode/trunk/axis2/src/main/wsdl/deploy.wsdl
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/main/wsdl/deploy.wsdl?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/axis2/src/main/wsdl/deploy.wsdl (original)
+++ ode/trunk/axis2/src/main/wsdl/deploy.wsdl Tue Feb 17 22:15:22 2009
@@ -28,32 +28,32 @@
<types>
<xsd:schema elementFormDefault="qualified"
- targetNamespace="http://www.apache.org/ode/deployapi">
- <xsd:import namespace="http://www.w3.org/2005/05/xmlmime"
- schemaLocation="xmlmime.xsd" />
- <xsd:complexType name="package">
- <xsd:all>
- <xsd:element name="zip" type="xmime:base64Binary"
- xmime:expectedContentType="application/zip" />
- </xsd:all>
- </xsd:complexType>
- <xsd:complexType name="packageNames">
- <xsd:all>
- <xsd:element name="name" type="xsd:string" />
- </xsd:all>
- </xsd:complexType>
- <xsd:complexType name="processIds">
- <xsd:all>
- <xsd:element name="id" type="xsd:QName" />
- </xsd:all>
- </xsd:complexType>
- <xsd:complexType name="deployUnit">
- <xsd:sequence>
- <xsd:element name="name" type="xsd:string" />
- <xsd:element name="id" type="xsd:QName"
- maxOccurs="unbounded" />
- </xsd:sequence>
- </xsd:complexType>
+ targetNamespace="http://www.apache.org/ode/deployapi">
+ <xsd:import namespace="http://www.w3.org/2005/05/xmlmime"
+ schemaLocation="xmlmime.xsd" />
+ <xsd:complexType name="package">
+ <xsd:all>
+ <xsd:element name="zip" type="xmime:base64Binary"
+ xmime:expectedContentType="application/zip" />
+ </xsd:all>
+ </xsd:complexType>
+ <xsd:complexType name="packageNames">
+ <xsd:all>
+ <xsd:element name="name" type="xsd:string" />
+ </xsd:all>
+ </xsd:complexType>
+ <xsd:complexType name="processIds">
+ <xsd:all>
+ <xsd:element name="id" type="xsd:QName" />
+ </xsd:all>
+ </xsd:complexType>
+ <xsd:complexType name="deployUnit">
+ <xsd:sequence>
+ <xsd:element name="name" type="xsd:string" />
+ <xsd:element name="id" type="xsd:QName"
+ maxOccurs="unbounded" />
+ </xsd:sequence>
+ </xsd:complexType>
</xsd:schema>
</types>
Modified: ode/trunk/axis2/src/test/resources/HelloWorld.wsdl
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/test/resources/HelloWorld.wsdl?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/axis2/src/test/resources/HelloWorld.wsdl (original)
+++ ode/trunk/axis2/src/test/resources/HelloWorld.wsdl Tue Feb 17 22:15:22 2009
@@ -56,9 +56,9 @@
</wsdl:operation>
</wsdl:binding>
<wsdl:service name="HelloService">
- <wsdl:port name="HelloPort" binding="tns:HelloSoapBinding">
- <soap:address location="http://localhost:8080/ode/processes/helloWorld"/>
- </wsdl:port>
+ <wsdl:port name="HelloPort" binding="tns:HelloSoapBinding">
+ <soap:address location="http://localhost:8080/ode/processes/helloWorld"/>
+ </wsdl:port>
</wsdl:service>
<plnk:partnerLinkType name="HelloPartnerLinkType">
Modified: ode/trunk/axis2/src/test/resources/testRequest1.xml
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/test/resources/testRequest1.xml?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/axis2/src/test/resources/testRequest1.xml (original)
+++ ode/trunk/axis2/src/test/resources/testRequest1.xml Tue Feb 17 22:15:22 2009
@@ -19,8 +19,8 @@
<message>
<parameters>
<getObjectId foo="bar" xmlns="http://documentum.com/ws/2005/services">
- <someFooBar/>
- <barbaz xmlns="" />
+ <someFooBar/>
+ <barbaz xmlns="" />
</getObjectId>
</parameters>
Modified: ode/trunk/axis2/src/test/resources/testRequest1Bad.xml
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/test/resources/testRequest1Bad.xml?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/axis2/src/test/resources/testRequest1Bad.xml (original)
+++ ode/trunk/axis2/src/test/resources/testRequest1Bad.xml Tue Feb 17 22:15:22 2009
@@ -19,7 +19,7 @@
<message>
<wrongname>
<getObjectId xmlns="http://documentum.com/ws/2005/services">
- <someFooBar/>
+ <someFooBar/>
</getObjectId>
</wrongname>
</message>
\ No newline at end of file
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKey.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKey.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKey.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKey.java Tue Feb 17 22:15:22 2009
@@ -71,7 +71,7 @@
public CorrelationKey(String canonicalForm) {
int firstTilde = -1;
if (canonicalForm != null) {
- firstTilde = canonicalForm.indexOf('~') ;
+ firstTilde = canonicalForm.indexOf('~') ;
_csetId = Integer.parseInt(canonicalForm.substring(0, firstTilde == -1 ? canonicalForm.length() : firstTilde));
}
@@ -134,11 +134,11 @@
* otherwise <code>false</code>
*/
public boolean isUnique() {
- return unique;
+ return unique;
}
public void setUnique(boolean unique) {
- this.unique = unique;
+ this.unique = unique;
}
/**
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java Tue Feb 17 22:15:22 2009
@@ -23,7 +23,7 @@
*/
public class ProcessState {
- /** <em>NEW</em> state: instance has not been reduced. */
+ /** <em>NEW</em> state: instance has not been reduced. */
public static final short STATE_NEW = 0;
/**
@@ -102,7 +102,7 @@
* @return <code>true</code> if the process is finished.
*/
public static boolean isFinished(short state){
- return !(canExecute(state) || state == STATE_SUSPENDED);
+ return !(canExecute(state) || state == STATE_SUSPENDED);
}
/**
* Change <code>short</code> state representation to human-readable form.
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityDisabledEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityDisabledEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityDisabledEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityDisabledEvent.java Tue Feb 17 22:15:22 2009
@@ -23,6 +23,6 @@
*/
public class ActivityDisabledEvent extends ActivityEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java Tue Feb 17 22:15:22 2009
@@ -23,6 +23,6 @@
*/
public class ActivityEnabledEvent extends ActivityEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java Tue Feb 17 22:15:22 2009
@@ -23,6 +23,6 @@
* Event indicating that the activity completed execution.
*/
public class ActivityExecEndEvent extends ActivityEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java Tue Feb 17 22:15:22 2009
@@ -22,6 +22,6 @@
* Event sent when the <em>body</em> of the activity starts executing.
*/
public class ActivityExecStartEvent extends ActivityEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java Tue Feb 17 22:15:22 2009
@@ -23,7 +23,7 @@
*/
public class ActivityRecoveryEvent extends ActivityEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
private String _action;
@@ -35,7 +35,7 @@
_action = action;
}
- public String getRecoveryAction() {
+ public String getRecoveryAction() {
return _action;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java Tue Feb 17 22:15:22 2009
@@ -19,7 +19,7 @@
package org.apache.ode.bpel.evt;
public class CompensationHandlerRegistered extends ScopeEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
public TYPE getType() {
return TYPE.scopeHandling;
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java Tue Feb 17 22:15:22 2009
@@ -38,17 +38,17 @@
}
/** Message exchange port type*/
- public QName getPortType() {
+ public QName getPortType() {
return _portType;
}
- /** Message exchange operation */
- public String getOperation() {
+ /** Message exchange operation */
+ public String getOperation() {
return _operation;
}
/** Message exchange id */
- public String getMessageExchangeId() {
+ public String getMessageExchangeId() {
return _mexId;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java Tue Feb 17 22:15:22 2009
@@ -35,7 +35,7 @@
_correlationKey = correlationKey;
}
- public CorrelationKey getCorrelationKey() {
+ public CorrelationKey getCorrelationKey() {
return _correlationKey;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java Tue Feb 17 22:15:22 2009
@@ -29,7 +29,7 @@
private QName _fault;
/** fault qname */
- public QName getFault() {
+ public QName getFault() {
return _fault;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java Tue Feb 17 22:15:22 2009
@@ -25,8 +25,8 @@
private static final long serialVersionUID = 1L;
private String _result;
- /** result of expression, cast as a string */
- public String getResult() {
+ /** result of expression, cast as a string */
+ public String getResult() {
return _result;
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java Tue Feb 17 22:15:22 2009
@@ -34,24 +34,24 @@
_fault = fault;
}
- /**
- * @param fault The fault to set.
- */
- public void setFault(QName fault) {
- _fault = fault;
- }
+ /**
+ * @param fault The fault to set.
+ */
+ public void setFault(QName fault) {
+ _fault = fault;
+ }
- /**
- * @return Returns the fault.
- */
- public QName getFault() {
- return _fault;
- }
+ /**
+ * @return Returns the fault.
+ */
+ public QName getFault() {
+ return _fault;
+ }
- public boolean isSuccess() {
- return _success;
- }
- public void setSuccess(boolean success) {
- _success = success;
- }
+ public boolean isSuccess() {
+ return _success;
+ }
+ public void setSuccess(boolean success) {
+ _success = success;
+ }
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java Tue Feb 17 22:15:22 2009
@@ -26,8 +26,8 @@
public class ScopeFaultEvent
extends ScopeEvent {
- private static final long serialVersionUID = 1L;
- private QName _faultType;
+ private static final long serialVersionUID = 1L;
+ private QName _faultType;
private int _faultLineNo = -1;
private String _explanation;
@@ -35,12 +35,12 @@
super();
}
- public int getFaultLineNo() {
- return _faultLineNo;
- }
- public void setFaultLineNo(int faultLineNo) {
- _faultLineNo = faultLineNo;
- }
+ public int getFaultLineNo() {
+ return _faultLineNo;
+ }
+ public void setFaultLineNo(int faultLineNo) {
+ _faultLineNo = faultLineNo;
+ }
public ScopeFaultEvent(QName faultType, int lineNo, String explanation) {
_faultType = faultType;
_faultLineNo = lineNo;
@@ -49,10 +49,10 @@
/**
- * Get the fault type.
- * @return the fault type
- */
- public QName getFaultType() {
+ * Get the fault type.
+ * @return the fault type
+ */
+ public QName getFaultType() {
return _faultType;
}
@@ -60,11 +60,11 @@
_faultType = faultType;
}
- public String getExplanation() {
- return _explanation;
- }
-
- public void setExplanation(String explanation) {
- _explanation = explanation;
- }
+ public String getExplanation() {
+ return _explanation;
+ }
+
+ public void setExplanation(String explanation) {
+ _explanation = explanation;
+ }
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensibleElement.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensibleElement.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensibleElement.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensibleElement.java Tue Feb 17 22:15:22 2009
@@ -26,7 +26,7 @@
* @author Tammo van Lessen (University of Stuttgart)
*/
public interface ExtensibleElement {
-
- Element getNestedElement();
-
+
+ Element getNestedElement();
+
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensionOperation.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensionOperation.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensionOperation.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/extension/ExtensionOperation.java Tue Feb 17 22:15:22 2009
@@ -35,19 +35,19 @@
*/
public interface ExtensionOperation {
-
- /**
- * Provides the runtime implementation.
- *
- * <strong>Note:</strong> This method MAY run concurrently. Since Xerces' DOM
- * implementation is not thread-safe, please make sure to synchronize the
- * access to <code>element</code> if necessary.
- *
- * @param context injected ExtensionContext
- * @param element the extension element (child of <code>extensionActivity</code>
- * or <code>extensionAssignOperation</code>
- * @throws FaultException
- */
- void run(Object context, Element element) throws FaultException;
-
+
+ /**
+ * Provides the runtime implementation.
+ *
+ * <strong>Note:</strong> This method MAY run concurrently. Since Xerces' DOM
+ * implementation is not thread-safe, please make sure to synchronize the
+ * access to <code>element</code> if necessary.
+ *
+ * @param context injected ExtensionContext
+ * @param element the extension element (child of <code>extensionActivity</code>
+ * or <code>extensionAssignOperation</code>
+ * @throws FaultException
+ */
+ void run(Object context, Element element) throws FaultException;
+
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java Tue Feb 17 22:15:22 2009
@@ -36,7 +36,7 @@
* @param bpelEvent BPEL event
*/
void onEvent(BpelEvent bpelEvent);
-
+
/**
* Allows the initialisation of listeners. Called directly
* after removing the listener from the listeners list.
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java Tue Feb 17 22:15:22 2009
@@ -27,32 +27,32 @@
* to JMX {@link javax.management.NotificationListener}s.
*/
public class BpelEventNotification extends Notification {
- private static final long serialVersionUID = 5420803960639317141L;
+ private static final long serialVersionUID = 5420803960639317141L;
- /**
- * Constructor. Creates a JMX notification with a type matching the
- * <em>class name</em> of the passed-in {@link BpelEvent} object.
- *
- * @param source
- * originating object/{@link javax.management.ObjectName}
- * @param sequence
- * event sequence
- * @param bpelEvent
- * {@link BpelEvent} payload
- */
- public BpelEventNotification(Object source, long sequence,
- BpelEvent bpelEvent) {
- super(bpelEvent.getClass().getName(), source, sequence);
- setUserData(bpelEvent);
- }
+ /**
+ * Constructor. Creates a JMX notification with a type matching the
+ * <em>class name</em> of the passed-in {@link BpelEvent} object.
+ *
+ * @param source
+ * originating object/{@link javax.management.ObjectName}
+ * @param sequence
+ * event sequence
+ * @param bpelEvent
+ * {@link BpelEvent} payload
+ */
+ public BpelEventNotification(Object source, long sequence,
+ BpelEvent bpelEvent) {
+ super(bpelEvent.getClass().getName(), source, sequence);
+ setUserData(bpelEvent);
+ }
- /**
- * Get the {@link BpelEvent} payload.
- *
- * @return {@link BpelEvent} payload.
- */
- public BpelEvent getBpelEvent() {
- return (BpelEvent) getUserData();
- }
+ /**
+ * Get the {@link BpelEvent} payload.
+ *
+ * @return {@link BpelEvent} payload.
+ */
+ public BpelEvent getBpelEvent() {
+ return (BpelEvent) getUserData();
+ }
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ConstantsModel.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ConstantsModel.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ConstantsModel.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ConstantsModel.java Tue Feb 17 22:15:22 2009
@@ -3,7 +3,7 @@
import javax.xml.namespace.QName;
public interface ConstantsModel {
-
+
// standard fault names
public QName getMissingRequest();
public QName getMissingReply();
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/CorrelationSet.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/CorrelationSet.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/CorrelationSet.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/CorrelationSet.java Tue Feb 17 22:15:22 2009
@@ -2,7 +2,7 @@
public interface CorrelationSet extends org.apache.ode.bpel.rapi.ScopedObject {
- String getName();
-
- ProcessModel getOwner();
+ String getName();
+
+ ProcessModel getOwner();
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/FaultInfo.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/FaultInfo.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/FaultInfo.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/FaultInfo.java Tue Feb 17 22:15:22 2009
@@ -6,14 +6,14 @@
public interface FaultInfo {
- QName getFaultName();
+ QName getFaultName();
- String getExplanation();
+ String getExplanation();
- int getFaultLineNo();
+ int getFaultLineNo();
- int getActivityId();
+ int getActivityId();
- Element getFaultMessage();
+ Element getFaultMessage();
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/OdeRTInstanceContext.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/OdeRTInstanceContext.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/OdeRTInstanceContext.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/OdeRTInstanceContext.java Tue Feb 17 22:15:22 2009
@@ -39,21 +39,21 @@
*/
public interface OdeRTInstanceContext extends IOContext, ProcessControlContext, RecoveryContext, VariableContext {
- Long getPid();
+ Long getPid();
- /**
- * Sends the bpel event.
- *
- * @param event
- */
- void sendEvent(ProcessInstanceEvent event);
-
- /**
- * Generate a unique (and monotonic) ID in the context of this instance.
- *
- * @return
- */
- long genId();
+ /**
+ * Sends the bpel event.
+ *
+ * @param event
+ */
+ void sendEvent(ProcessInstanceEvent event);
+
+ /**
+ * Generate a unique (and monotonic) ID in the context of this instance.
+ *
+ * @return
+ */
+ long genId();
/**
* @param mexId
@@ -61,17 +61,17 @@
*/
void noreply(String mexId, FaultInfo optionalFaultData);
- int getAtomicScopeRetryDelay();
+ int getAtomicScopeRetryDelay();
- boolean isAtomicScopeFirstTry();
+ boolean isAtomicScopeFirstTry();
- boolean isAtomicScopeRetryable();
+ boolean isAtomicScopeRetryable();
- void setAtomicScopeRetriedOnce();
+ void setAtomicScopeRetriedOnce();
- void setAtomicScopeRetriesDone();
+ void setAtomicScopeRetriesDone();
- void setAtomicScope(boolean atomicScope);
+ void setAtomicScope(boolean atomicScope);
- Node getProcessProperty(QName propertyName);
+ Node getProcessProperty(QName propertyName);
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLink.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLink.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLink.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLink.java Tue Feb 17 22:15:22 2009
@@ -2,7 +2,7 @@
public interface PartnerLink extends ScopedObject {
- String getName();
+ String getName();
- PartnerLinkModel getModel();
+ PartnerLinkModel getModel();
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLinkModel.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLinkModel.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLinkModel.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/PartnerLinkModel.java Tue Feb 17 22:15:22 2009
@@ -5,30 +5,30 @@
import java.util.Set;
public interface PartnerLinkModel {
-
- int getId();
-
- String getName();
-
- boolean hasMyRole();
+
+ int getId();
+
+ String getName();
+
+ boolean hasMyRole();
- boolean hasPartnerRole();
+ boolean hasPartnerRole();
- String getMyRoleName();
+ String getMyRoleName();
- Operation getMyRoleOperation(String operation);
+ Operation getMyRoleOperation(String operation);
- String getPartnerRoleName();
-
- Operation getPartnerRoleOperation(String operation);
+ String getPartnerRoleName();
+
+ Operation getPartnerRoleOperation(String operation);
- boolean isInitializePartnerRoleSet();
+ boolean isInitializePartnerRoleSet();
- PortType getMyRolePortType();
+ PortType getMyRolePortType();
- PortType getPartnerRolePortType();
+ PortType getPartnerRolePortType();
- boolean isCreateInstanceOperation(Operation operation);
+ boolean isCreateInstanceOperation(Operation operation);
Set<CorrelationSetModel> getCorrelationSetsForOperation(Operation operation);
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessControlContext.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessControlContext.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessControlContext.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessControlContext.java Tue Feb 17 22:15:22 2009
@@ -9,27 +9,27 @@
*/
public interface ProcessControlContext {
- void forceFlush();
+ void forceFlush();
- void forceRollback();
-
- /**
- * Should be invoked by process template, signalling process completion with
- * no faults.
- *
- */
- void completedOk();
+ void forceRollback();
+
+ /**
+ * Should be invoked by process template, signalling process completion with
+ * no faults.
+ *
+ */
+ void completedOk();
- /**
- * Should be invoked by process template, signalling process completion with
- * fault.
- */
- void completedFault(FaultInfo faultData);
+ /**
+ * Should be invoked by process template, signalling process completion with
+ * fault.
+ */
+ void completedFault(FaultInfo faultData);
- /**
- * Terminates the process / sets state flag to terminate and ceases all
- * processing for the instance.
- */
- void terminate();
+ /**
+ * Terminates the process / sets state flag to terminate and ceases all
+ * processing for the instance.
+ */
+ void terminate();
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessModel.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessModel.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessModel.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ProcessModel.java Tue Feb 17 22:15:22 2009
@@ -7,17 +7,17 @@
public interface ProcessModel {
- PartnerLinkModel getPartnerLink(String name);
-
- PartnerLinkModel getPartnerLink(int partnerLinkModelId);
+ PartnerLinkModel getPartnerLink(String name);
+
+ PartnerLinkModel getPartnerLink(int partnerLinkModelId);
- Collection<? extends PartnerLinkModel> getAllPartnerLinks();
+ Collection<? extends PartnerLinkModel> getAllPartnerLinks();
- String getGuid();
+ String getGuid();
- QName getQName();
+ QName getQName();
- List<String> getCorrelators();
+ List<String> getCorrelators();
ActivityModel getChild(final int id);
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/RecoveryContext.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/RecoveryContext.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/RecoveryContext.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/RecoveryContext.java Tue Feb 17 22:15:22 2009
@@ -11,12 +11,12 @@
*
*/
public interface RecoveryContext {
-
- void registerActivityForRecovery(String channel, long activityId,
- String reason, Date dateTime, Element details, String[] actions,
- int retries);
+
+ void registerActivityForRecovery(String channel, long activityId,
+ String reason, Date dateTime, Element details, String[] actions,
+ int retries);
- void unregisterActivityForRecovery(String channel);
+ void unregisterActivityForRecovery(String channel);
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ScopedObject.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ScopedObject.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ScopedObject.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/ScopedObject.java Tue Feb 17 22:15:22 2009
@@ -2,5 +2,5 @@
public interface ScopedObject {
- long getScopeId();
+ long getScopeId();
}
Modified: ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/Variable.java
URL: http://svn.apache.org/viewvc/ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/Variable.java?rev=745274&r1=745273&r2=745274&view=diff
==============================================================================
--- ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/Variable.java (original)
+++ ode/trunk/bpel-api/src/main/java/org/apache/ode/bpel/rapi/Variable.java Tue Feb 17 22:15:22 2009
@@ -4,10 +4,10 @@
public interface Variable extends ScopedObject {
- String getName();
+ String getName();
String getExternalId();
QName getElementType();
-
+
}
|