You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mi...@apache.org on 2009/02/17 23:06:26 UTC
svn commit: r745271 [12/19] - in /ode/branches/APACHE_ODE_1.X: ./
axis2-war/src/main/webapp/ axis2-war/src/main/webapp/WEB-INF/
axis2-war/src/main/webapp/WEB-INF/classes/
axis2-war/src/main/webapp/WEB-INF/conf.hib-derby/
axis2-war/src/main/webapp/WEB-I...
Modified: ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentBrowser.java Tue Feb 17 22:06:18 2009
@@ -144,13 +144,13 @@
}
});
} else if (segments.length > 2) {
- List<QName> processes = _store.listProcesses(segments[1]);
+ 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() {
+ renderXml(response, new DocBody() {
public void render(Writer out) throws IOException {
write(out, file.getPath());
}
@@ -167,73 +167,73 @@
}
}
} 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>");
- }
- });
-
- }
- }
+ 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>");
- }
- });
- }
- }
-
- }
+ 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;
@@ -254,7 +254,7 @@
out.write("</body></html>");
}
private void renderXml(HttpServletResponse response, DocBody docBody) throws IOException {
- response.setContentType("application/xml; charset=utf-8");
+ response.setContentType("application/xml; charset=utf-8");
//response.setContentType("application/xml");
//response.setCharacterEncoding("UTF-8");
Modified: ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/DeploymentWebService.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/ManagementService.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/ManagementService.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/ManagementService.java (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/service/ManagementService.java Tue Feb 17 22:06:18 2009
@@ -151,6 +151,6 @@
soapDetail.addDetailEntry(detail);
return fault;
}
- }
+ }
}
Modified: ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/util/SoapMessageConverter.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/util/SoapMessageConverter.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/util/SoapMessageConverter.java (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/util/SoapMessageConverter.java Tue Feb 17 22:06:18 2009
@@ -130,11 +130,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());
}
}
Modified: ode/branches/APACHE_ODE_1.X/axis2/src/main/wsdl/deploy.wsdl
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/main/wsdl/deploy.wsdl?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/main/wsdl/deploy.wsdl (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/main/wsdl/deploy.wsdl Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/axis2/src/test/java/org/apache/ode/axis2/httpbinding/HttpMethodConverterTest.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/test/java/org/apache/ode/axis2/httpbinding/HttpMethodConverterTest.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/test/java/org/apache/ode/axis2/httpbinding/HttpMethodConverterTest.java (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/test/java/org/apache/ode/axis2/httpbinding/HttpMethodConverterTest.java Tue Feb 17 22:06:18 2009
@@ -348,11 +348,11 @@
}
- public int getSubscriberCount() {
- return 0;
- }
+ public int getSubscriberCount() {
+ return 0;
+ }
- public void setSubscriberCount(int subscriberCount) {
- }
+ public void setSubscriberCount(int subscriberCount) {
+ }
}
}
Modified: ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/HelloWorld.wsdl
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/HelloWorld.wsdl?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/HelloWorld.wsdl (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/HelloWorld.wsdl Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1.xml
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1.xml?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1.xml (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1.xml Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1Bad.xml
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1Bad.xml?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1Bad.xml (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/test/resources/testRequest1Bad.xml Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKeySet.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKeySet.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKeySet.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/CorrelationKeySet.java Tue Feb 17 22:06:18 2009
@@ -26,99 +26,99 @@
*
*/
public class CorrelationKeySet implements Serializable {
- private static final long serialVersionUID = 1L;
-
- public final static String VERSION_1 = "1";
- public final static String VERSION_2 = "2";
-
- @SuppressWarnings("unused")
- private String version = VERSION_2;
-
- private final Set<CorrelationKey> correlationKeys = new TreeSet<CorrelationKey>(new CorrelationKeyComparator());
-
- /**
- * Default Constructor
- */
- public CorrelationKeySet() {
- }
-
- /**
- * Restores the state by parsing the given canonical form of correlation key set.
- *
- * @param canonicalForm canonical form of correlation key set
- */
- public CorrelationKeySet(String canonicalForm) {
- restore(canonicalForm);
- }
-
- /**
- * Adds a correlation key to this correlation key set. If a correlation key with the same correlation set id
- * already exists, the old one is replaced with the given new one.
- *
- * @param ck a correlation key to add
- * @return returns this correlation key set
- */
- public CorrelationKeySet add(CorrelationKey ck) {
- for( CorrelationKey key : correlationKeys ) {
- if( key.getCorrelationSetName() == ck.getCorrelationSetName() ) {
- correlationKeys.remove(ck);
- break;
- }
- }
- correlationKeys.add(ck);
-
- return this;
- }
-
- /**
- * Checks if this correlation key set contains the opaque correlation key as the only key
- * in this correlation key set.
- *
- * @return returns true if the correlation key set is opaque
- */
- public boolean isOpaque() {
- return correlationKeys.size() == 1 && correlationKeys.iterator().next().getCorrelationSetName().equals("-1");
- }
-
- /**
- * Checks if an incoming message with this correlation key set can be accepted by the given
- * correlation key set.
- *
- * @param candidateKeySet a correlation key set stored in a route
- * @param isAllRoute use true if the route="all" is set
- * @return return true if routable
- */
- public boolean isRoutableTo(CorrelationKeySet candidateKeySet, boolean isAllRoute) {
- boolean isRoutable = containsAll(candidateKeySet);
-
- if( isAllRoute ) {
- isRoutable = isRoutable || candidateKeySet.isOpaque() && isEmpty();
- }
-
- return isRoutable;
- }
-
- /**
- * Checks if this correlation key set contains all correlation keys from the given correlation key set.
- *
- * @param c a correlation key set
- * @return return true if this correlation key set is a superset
- */
+ private static final long serialVersionUID = 1L;
+
+ public final static String VERSION_1 = "1";
+ public final static String VERSION_2 = "2";
+
+ @SuppressWarnings("unused")
+ private String version = VERSION_2;
+
+ private final Set<CorrelationKey> correlationKeys = new TreeSet<CorrelationKey>(new CorrelationKeyComparator());
+
+ /**
+ * Default Constructor
+ */
+ public CorrelationKeySet() {
+ }
+
+ /**
+ * Restores the state by parsing the given canonical form of correlation key set.
+ *
+ * @param canonicalForm canonical form of correlation key set
+ */
+ public CorrelationKeySet(String canonicalForm) {
+ restore(canonicalForm);
+ }
+
+ /**
+ * Adds a correlation key to this correlation key set. If a correlation key with the same correlation set id
+ * already exists, the old one is replaced with the given new one.
+ *
+ * @param ck a correlation key to add
+ * @return returns this correlation key set
+ */
+ public CorrelationKeySet add(CorrelationKey ck) {
+ for( CorrelationKey key : correlationKeys ) {
+ if( key.getCorrelationSetName() == ck.getCorrelationSetName() ) {
+ correlationKeys.remove(ck);
+ break;
+ }
+ }
+ correlationKeys.add(ck);
+
+ return this;
+ }
+
+ /**
+ * Checks if this correlation key set contains the opaque correlation key as the only key
+ * in this correlation key set.
+ *
+ * @return returns true if the correlation key set is opaque
+ */
+ public boolean isOpaque() {
+ return correlationKeys.size() == 1 && correlationKeys.iterator().next().getCorrelationSetName().equals("-1");
+ }
+
+ /**
+ * Checks if an incoming message with this correlation key set can be accepted by the given
+ * correlation key set.
+ *
+ * @param candidateKeySet a correlation key set stored in a route
+ * @param isAllRoute use true if the route="all" is set
+ * @return return true if routable
+ */
+ public boolean isRoutableTo(CorrelationKeySet candidateKeySet, boolean isAllRoute) {
+ boolean isRoutable = containsAll(candidateKeySet);
+
+ if( isAllRoute ) {
+ isRoutable = isRoutable || candidateKeySet.isOpaque() && isEmpty();
+ }
+
+ return isRoutable;
+ }
+
+ /**
+ * Checks if this correlation key set contains all correlation keys from the given correlation key set.
+ *
+ * @param c a correlation key set
+ * @return return true if this correlation key set is a superset
+ */
public boolean containsAll(CorrelationKeySet c) {
- Iterator<CorrelationKey> e = c.iterator();
- while (e.hasNext())
- if (!contains(e.next()))
- return false;
- return true;
- }
-
+ Iterator<CorrelationKey> e = c.iterator();
+ while (e.hasNext())
+ if (!contains(e.next()))
+ return false;
+ return true;
+ }
+
/**
* Returns true if this correlation key set contains no correlation keys.
*
* @return returns true if empty
*/
public boolean isEmpty() {
- return correlationKeys.isEmpty();
+ return correlationKeys.isEmpty();
}
/**
@@ -128,49 +128,49 @@
* @return
*/
public boolean contains(CorrelationKey correlationKey) {
- Iterator<CorrelationKey> e = correlationKeys.iterator();
- if (correlationKey == null) {
- while (e.hasNext())
- if (e.next() == null)
- return true;
- } else {
- while (e.hasNext()) {
- if (correlationKey.equals(e.next()))
- return true;
- }
- }
- return false;
- }
-
+ Iterator<CorrelationKey> e = correlationKeys.iterator();
+ if (correlationKey == null) {
+ while (e.hasNext())
+ if (e.next() == null)
+ return true;
+ } else {
+ while (e.hasNext()) {
+ if (correlationKey.equals(e.next()))
+ return true;
+ }
+ }
+ return false;
+ }
+
/**
* Returns an iterator on the correlation keys that this correlation key set contains.
*
* @return an iterator
*/
public Iterator<CorrelationKey> iterator() {
- return correlationKeys.iterator();
+ return correlationKeys.iterator();
}
/**
* Removes all correlation keys in this correlation keys.
*/
public void clear() {
- correlationKeys.clear();
+ correlationKeys.clear();
}
@Override
- public boolean equals(Object o) {
- if( o == null || !(o instanceof CorrelationKeySet) ) {
- return false;
- }
- CorrelationKeySet another = (CorrelationKeySet)o;
-
- if( correlationKeys.size() != another.correlationKeys.size() ) {
- return false;
- }
+ public boolean equals(Object o) {
+ if( o == null || !(o instanceof CorrelationKeySet) ) {
+ return false;
+ }
+ CorrelationKeySet another = (CorrelationKeySet)o;
+
+ if( correlationKeys.size() != another.correlationKeys.size() ) {
+ return false;
+ }
- return containsAll(another);
- }
+ return containsAll(another);
+ }
/**
* Finds all subsets of this correlation key set.
@@ -178,48 +178,48 @@
* @return a list of all subset correlation key sets
*/
public List<CorrelationKeySet> findSubSets() {
- List<CorrelationKeySet> subSets = new ArrayList<CorrelationKeySet>();
-
- // if the key set contains a opaque key and at least one non-opaque key, take out the opaque key
- CorrelationKey opaqueKey = null;
- boolean containsNonOpaque = false;
- CorrelationKeySet explicitKeySet = new CorrelationKeySet();
- for( CorrelationKey ckey : correlationKeys ) {
- // assumes only ONE opaque key if there is
- if( ckey.getCorrelationSetName().equals("-1") ) {
- opaqueKey = ckey;
- } else {
- containsNonOpaque = true;
- }
- explicitKeySet.add(ckey);
- }
- if( opaqueKey != null && containsNonOpaque ) {
- explicitKeySet.correlationKeys.remove(opaqueKey);
- }
-
- // we are generating (2 powered by the number of correlation keys) number of sub-sets
- for( int setIndex = 0; setIndex < Math.pow(2, explicitKeySet.correlationKeys.size()); setIndex++ ) {
- CorrelationKeySet subKeySet = new CorrelationKeySet();
- int bitPattern = setIndex; // the bitPattern will be 0b0000, 0b0001, 0b0010 and so on
- Iterator<CorrelationKey> ckeys = explicitKeySet.iterator();
- while( ckeys.hasNext() && bitPattern > 0 ) { // bitPattern > 0 condition saves half of the iterations
- CorrelationKey ckey = ckeys.next();
- if( (bitPattern & 0x01) > 0 ) {
- subKeySet.add(ckey);
- }
- bitPattern = bitPattern >> 1;
- }
-
- if(!subKeySet.isEmpty()) { // we don't want an empty set
- subSets.add(subKeySet);
- }
- }
-
- if( subSets.isEmpty() ) {
- subSets.add(new CorrelationKeySet());
- }
-
- return subSets;
+ List<CorrelationKeySet> subSets = new ArrayList<CorrelationKeySet>();
+
+ // if the key set contains a opaque key and at least one non-opaque key, take out the opaque key
+ CorrelationKey opaqueKey = null;
+ boolean containsNonOpaque = false;
+ CorrelationKeySet explicitKeySet = new CorrelationKeySet();
+ for( CorrelationKey ckey : correlationKeys ) {
+ // assumes only ONE opaque key if there is
+ if( ckey.getCorrelationSetName().equals("-1") ) {
+ opaqueKey = ckey;
+ } else {
+ containsNonOpaque = true;
+ }
+ explicitKeySet.add(ckey);
+ }
+ if( opaqueKey != null && containsNonOpaque ) {
+ explicitKeySet.correlationKeys.remove(opaqueKey);
+ }
+
+ // we are generating (2 powered by the number of correlation keys) number of sub-sets
+ for( int setIndex = 0; setIndex < Math.pow(2, explicitKeySet.correlationKeys.size()); setIndex++ ) {
+ CorrelationKeySet subKeySet = new CorrelationKeySet();
+ int bitPattern = setIndex; // the bitPattern will be 0b0000, 0b0001, 0b0010 and so on
+ Iterator<CorrelationKey> ckeys = explicitKeySet.iterator();
+ while( ckeys.hasNext() && bitPattern > 0 ) { // bitPattern > 0 condition saves half of the iterations
+ CorrelationKey ckey = ckeys.next();
+ if( (bitPattern & 0x01) > 0 ) {
+ subKeySet.add(ckey);
+ }
+ bitPattern = bitPattern >> 1;
+ }
+
+ if(!subKeySet.isEmpty()) { // we don't want an empty set
+ subSets.add(subKeySet);
+ }
+ }
+
+ if( subSets.isEmpty() ) {
+ subSets.add(new CorrelationKeySet());
+ }
+
+ return subSets;
}
/**
@@ -231,10 +231,10 @@
StringBuffer buf = new StringBuffer();
for( CorrelationKey ckey : correlationKeys ) {
- if( buf.length() > 0 ) {
- buf.append(",");
- }
- buf.append("[").append(escapeRightBracket(ckey.toCanonicalString())).append("]");
+ if( buf.length() > 0 ) {
+ buf.append(",");
+ }
+ buf.append("[").append(escapeRightBracket(ckey.toCanonicalString())).append("]");
}
return "@" + VERSION_2 + buf.toString();
@@ -245,7 +245,7 @@
return null;
StringBuffer buf = new StringBuffer();
-
+
char[] chars = str.toCharArray();
for (char achar : chars) {
if (achar == ']') {
@@ -260,7 +260,7 @@
@Override
public String toString() {
- return correlationKeys.toString();
+ return correlationKeys.toString();
}
/**
@@ -268,90 +268,90 @@
*
* @param canonicalForm a canonical form of correlation key set
*/
- public void restore(String canonicalForm) {
- if( canonicalForm == null || canonicalForm.trim().length() == 0 ) return;
+ public void restore(String canonicalForm) {
+ if( canonicalForm == null || canonicalForm.trim().length() == 0 ) return;
+
+ if( canonicalForm.startsWith("@") ) {
+ parseCanonicalForm(canonicalForm);
+ } else {
+ version = VERSION_1;
+ add( new CorrelationKey(canonicalForm) );
+ }
+ }
- if( canonicalForm.startsWith("@") ) {
- parseCanonicalForm(canonicalForm);
- } else {
- version = VERSION_1;
- add( new CorrelationKey(canonicalForm) );
- }
- }
-
- private static enum ParserState {
- INITIAL, MET_ALPHA, MET_LEFT_BRACKET, MET_RIGHT_BRACKET, MET_COMMA
- }
-
- // parses a canonical form of correlation key set through an automata subsystem(FSM)
- private void parseCanonicalForm(String canonicalForm) {
- ParserState state = ParserState.INITIAL;
-
- StringBuffer buf = new StringBuffer();
- for( int i = 0; i < canonicalForm.length(); i++ ) {
- char ch = canonicalForm.charAt(i);
- if( state == ParserState.INITIAL ) {
- if( ch == '@' ) {
- state = ParserState.MET_ALPHA;
- } else {
- buf.append(ch);
- state = ParserState.MET_LEFT_BRACKET;
- }
- } else if( state == ParserState.MET_ALPHA ) {
- if( ch == '[' ) {
- version = buf.toString();
- buf.setLength(0);
- state = ParserState.MET_LEFT_BRACKET;
- } else {
- buf.append(ch);
- }
- } else if( state == ParserState.MET_LEFT_BRACKET ) {
- if( ch == ']' ) {
- state = ParserState.MET_RIGHT_BRACKET;
- } else {
- buf.append(ch);
- }
- } else if( state == ParserState.MET_RIGHT_BRACKET ) {
- if( ch == ']' ) {
- buf.append(ch);
- state = ParserState.MET_LEFT_BRACKET;
- } else if( ch == ',' ) {
- if( buf.toString().trim().length() != 0 ) {
- add( new CorrelationKey(buf.toString()) );
- }
- buf.setLength(0);
- state = ParserState.MET_COMMA;
- } else if( ch == '?' ) { // this is only a convenient feature for testing
- if( buf.toString().trim().length() != 0 ) {
- add( new OptionalCorrelationKey(buf.toString()) );
- }
- buf.setLength(0);
- state = ParserState.MET_COMMA;
- }
- } else if( state == ParserState.MET_COMMA ) {
- if( ch == '[' ) {
- state = ParserState.MET_LEFT_BRACKET;
- }
- }
- }
- if( buf.toString().trim().length() != 0 ) {
- if( state == ParserState.MET_ALPHA ) {
- version = buf.toString();
- } else {
- add( new CorrelationKey(buf.toString()) );
- }
- }
- }
+ private static enum ParserState {
+ INITIAL, MET_ALPHA, MET_LEFT_BRACKET, MET_RIGHT_BRACKET, MET_COMMA
+ }
+
+ // parses a canonical form of correlation key set through an automata subsystem(FSM)
+ private void parseCanonicalForm(String canonicalForm) {
+ ParserState state = ParserState.INITIAL;
+
+ StringBuffer buf = new StringBuffer();
+ for( int i = 0; i < canonicalForm.length(); i++ ) {
+ char ch = canonicalForm.charAt(i);
+ if( state == ParserState.INITIAL ) {
+ if( ch == '@' ) {
+ state = ParserState.MET_ALPHA;
+ } else {
+ buf.append(ch);
+ state = ParserState.MET_LEFT_BRACKET;
+ }
+ } else if( state == ParserState.MET_ALPHA ) {
+ if( ch == '[' ) {
+ version = buf.toString();
+ buf.setLength(0);
+ state = ParserState.MET_LEFT_BRACKET;
+ } else {
+ buf.append(ch);
+ }
+ } else if( state == ParserState.MET_LEFT_BRACKET ) {
+ if( ch == ']' ) {
+ state = ParserState.MET_RIGHT_BRACKET;
+ } else {
+ buf.append(ch);
+ }
+ } else if( state == ParserState.MET_RIGHT_BRACKET ) {
+ if( ch == ']' ) {
+ buf.append(ch);
+ state = ParserState.MET_LEFT_BRACKET;
+ } else if( ch == ',' ) {
+ if( buf.toString().trim().length() != 0 ) {
+ add( new CorrelationKey(buf.toString()) );
+ }
+ buf.setLength(0);
+ state = ParserState.MET_COMMA;
+ } else if( ch == '?' ) { // this is only a convenient feature for testing
+ if( buf.toString().trim().length() != 0 ) {
+ add( new OptionalCorrelationKey(buf.toString()) );
+ }
+ buf.setLength(0);
+ state = ParserState.MET_COMMA;
+ }
+ } else if( state == ParserState.MET_COMMA ) {
+ if( ch == '[' ) {
+ state = ParserState.MET_LEFT_BRACKET;
+ }
+ }
+ }
+ if( buf.toString().trim().length() != 0 ) {
+ if( state == ParserState.MET_ALPHA ) {
+ version = buf.toString();
+ } else {
+ add( new CorrelationKey(buf.toString()) );
+ }
+ }
+ }
private class CorrelationKeyComparator implements Serializable, Comparator<CorrelationKey> {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
- public int compare(CorrelationKey o1, CorrelationKey o2) {
- if( o1 == null || o2 == null ) {
- return 0;
- }
- // used only in sorting the correlation keys in the CorrelationKeySet; does not matter with the values
- return o1.getCorrelationSetName().compareTo(o2.getCorrelationSetName());
- }
+ public int compare(CorrelationKey o1, CorrelationKey o2) {
+ if( o1 == null || o2 == null ) {
+ return 0;
+ }
+ // used only in sorting the correlation keys in the CorrelationKeySet; does not matter with the values
+ return o1.getCorrelationSetName().compareTo(o2.getCorrelationSetName());
+ }
}
}
\ No newline at end of file
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/OptionalCorrelationKey.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/OptionalCorrelationKey.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/OptionalCorrelationKey.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/OptionalCorrelationKey.java Tue Feb 17 22:06:18 2009
@@ -18,11 +18,11 @@
private static final long serialVersionUID = 1L;
public OptionalCorrelationKey(String csetName, String[] keyValues) {
- super(csetName, keyValues);
+ super(csetName, keyValues);
}
public OptionalCorrelationKey(String canonicalForm) {
- super(canonicalForm);
+ super(canonicalForm);
}
/**
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/common/ProcessState.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityEnabledEvent.java Tue Feb 17 22:06:18 2009
@@ -23,6 +23,6 @@
*/
public class ActivityEnabledEvent extends ActivityEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecEndEvent.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityExecStartEvent.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ActivityRecoveryEvent.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CompensationHandlerRegistered.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationEvent.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationMatchEvent.java Tue Feb 17 22:06:18 2009
@@ -27,36 +27,36 @@
* Correlation matched a process instance on inbound message.
*/
public class CorrelationMatchEvent extends ProcessMessageExchangeEvent {
- private static final long serialVersionUID = 1L;
+ private static final long serialVersionUID = 1L;
- // left out for backward-compatibility
- private CorrelationKey _correlationKey;
- private CorrelationKeySet _correlationKeySet;
+ // left out for backward-compatibility
+ private CorrelationKey _correlationKey;
+ private CorrelationKeySet _correlationKeySet;
- public CorrelationMatchEvent(QName processName, QName processId, Long processInstanceId, CorrelationKeySet correlationKeySet) {
- super(PROCESS_INPUT, processName, processId, processInstanceId);
- _correlationKeySet = correlationKeySet;
- }
+ public CorrelationMatchEvent(QName processName, QName processId, Long processInstanceId, CorrelationKeySet correlationKeySet) {
+ super(PROCESS_INPUT, processName, processId, processInstanceId);
+ _correlationKeySet = correlationKeySet;
+ }
- public CorrelationKeySet getCorrelationKeySet() {
- // backward compatibility; add up
- if (_correlationKey != null) {
- if( _correlationKeySet == null ) {
- _correlationKeySet = new CorrelationKeySet();
- }
- if(!_correlationKeySet.contains(_correlationKey)) {
- _correlationKeySet.add(_correlationKey);
- }
- }
-
- return _correlationKeySet;
- }
+ public CorrelationKeySet getCorrelationKeySet() {
+ // backward compatibility; add up
+ if (_correlationKey != null) {
+ if( _correlationKeySet == null ) {
+ _correlationKeySet = new CorrelationKeySet();
+ }
+ if(!_correlationKeySet.contains(_correlationKey)) {
+ _correlationKeySet.add(_correlationKey);
+ }
+ }
+
+ return _correlationKeySet;
+ }
- public void setCorrelationKey(CorrelationKeySet correlationKeySet) {
- _correlationKeySet = correlationKeySet;
- }
+ public void setCorrelationKey(CorrelationKeySet correlationKeySet) {
+ _correlationKeySet = correlationKeySet;
+ }
- public TYPE getType() {
- return TYPE.correlation;
- }
+ public TYPE getType() {
+ return TYPE.correlation;
+ }
}
\ No newline at end of file
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationNoMatchEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationNoMatchEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationNoMatchEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/CorrelationNoMatchEvent.java Tue Feb 17 22:06:18 2009
@@ -31,35 +31,35 @@
* match
*/
public class CorrelationNoMatchEvent extends CorrelationEvent {
- private static final long serialVersionUID = 1L;
-
- // left out for backward-compatibility
- private final Set<CorrelationKey> _keys = new HashSet<CorrelationKey>();
- private CorrelationKeySet _keySet = null;
+ private static final long serialVersionUID = 1L;
+
+ // left out for backward-compatibility
+ private final Set<CorrelationKey> _keys = new HashSet<CorrelationKey>();
+ private CorrelationKeySet _keySet = null;
- public CorrelationNoMatchEvent(QName qName, String opName, String mexId,
- CorrelationKeySet keySet) {
- super(qName, opName, mexId);
+ public CorrelationNoMatchEvent(QName qName, String opName, String mexId,
+ CorrelationKeySet keySet) {
+ super(qName, opName, mexId);
- _keySet = keySet;
- }
+ _keySet = keySet;
+ }
- public CorrelationKeySet getKeySet() {
- // backward-compatibility; add up keys
- if( _keys.size() > 0 && _keySet == null ) {
- _keySet = new CorrelationKeySet();
- }
- for (CorrelationKey aKey : _keys) {
- if (aKey != null && !_keySet.contains(aKey)) {
- _keySet.add(aKey);
- }
- }
-
- return _keySet;
- }
+ public CorrelationKeySet getKeySet() {
+ // backward-compatibility; add up keys
+ if( _keys.size() > 0 && _keySet == null ) {
+ _keySet = new CorrelationKeySet();
+ }
+ for (CorrelationKey aKey : _keys) {
+ if (aKey != null && !_keySet.contains(aKey)) {
+ _keySet.add(aKey);
+ }
+ }
+
+ return _keySet;
+ }
- public void setKeys(CorrelationKeySet keySet) {
- _keySet = keySet;
- }
+ public void setKeys(CorrelationKeySet keySet) {
+ _keySet = keySet;
+ }
}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationFailedEvent.java Tue Feb 17 22:06:18 2009
@@ -29,7 +29,7 @@
private QName _fault;
/** fault qname */
- public QName getFault() {
+ public QName getFault() {
return _fault;
}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ExpressionEvaluationSuccessEvent.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStartedEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStartedEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStartedEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStartedEvent.java Tue Feb 17 22:06:18 2009
@@ -1,50 +1,50 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.ode.bpel.evt;
-
-/**
- * Event indicating the start (post creation) of a new process instance.
- */
-public class ProcessInstanceStartedEvent extends ProcessInstanceEvent {
-
- private static final long serialVersionUID = -4245567193743622300L;
- private Long _rootScopeId;
- private int _scopeDeclarationId;
-
- public ProcessInstanceStartedEvent() {
- super();
- }
-
- public Long getRootScopeId() {
- return _rootScopeId;
- }
-
- public void setRootScopeId(Long rootScopeId) {
- _rootScopeId = rootScopeId;
- }
-
- public int getScopeDeclarationId() {
- return _scopeDeclarationId;
- }
-
- public void setScopeDeclarationId(int scopeDeclarationId) {
- _scopeDeclarationId = scopeDeclarationId;
- }
-
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.ode.bpel.evt;
+
+/**
+ * Event indicating the start (post creation) of a new process instance.
+ */
+public class ProcessInstanceStartedEvent extends ProcessInstanceEvent {
+
+ private static final long serialVersionUID = -4245567193743622300L;
+ private Long _rootScopeId;
+ private int _scopeDeclarationId;
+
+ public ProcessInstanceStartedEvent() {
+ super();
+ }
+
+ public Long getRootScopeId() {
+ return _rootScopeId;
+ }
+
+ public void setRootScopeId(Long rootScopeId) {
+ _rootScopeId = rootScopeId;
+ }
+
+ public int getScopeDeclarationId() {
+ return _scopeDeclarationId;
+ }
+
+ public void setScopeDeclarationId(int scopeDeclarationId) {
+ _scopeDeclarationId = scopeDeclarationId;
+ }
+
+}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStateChangeEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStateChangeEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStateChangeEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessInstanceStateChangeEvent.java Tue Feb 17 22:06:18 2009
@@ -1,49 +1,49 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.ode.bpel.evt;
-
-/**
- * Event indicating the start (post creation) of a new process instance.
- */
-public class ProcessInstanceStateChangeEvent extends ProcessInstanceEvent {
- private static final long serialVersionUID = 5145501369806670539L;
- private short _oldState;
- private short _newState;
-
- public ProcessInstanceStateChangeEvent() {
- super();
- }
-
- public short getOldState() {
- return _oldState;
- }
-
- public void setOldState(short state) {
- _oldState = state;
- }
-
- public short getNewState() {
- return _newState;
- }
-
- public void setNewState(short state) {
- _newState = state;
- }
-
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.ode.bpel.evt;
+
+/**
+ * Event indicating the start (post creation) of a new process instance.
+ */
+public class ProcessInstanceStateChangeEvent extends ProcessInstanceEvent {
+ private static final long serialVersionUID = 5145501369806670539L;
+ private short _oldState;
+ private short _newState;
+
+ public ProcessInstanceStateChangeEvent() {
+ super();
+ }
+
+ public short getOldState() {
+ return _oldState;
+ }
+
+ public void setOldState(short state) {
+ _oldState = state;
+ }
+
+ public short getNewState() {
+ return _newState;
+ }
+
+ public void setNewState(short state) {
+ _newState = state;
+ }
+
+}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessMessageExchangeEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessMessageExchangeEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessMessageExchangeEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessMessageExchangeEvent.java Tue Feb 17 22:06:18 2009
@@ -1,88 +1,88 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.ode.bpel.evt;
-
-import javax.xml.namespace.QName;
-
-/**
- *
- */
-public class ProcessMessageExchangeEvent extends ProcessInstanceEvent {
-
- private static final long serialVersionUID = 1L;
-
- public static final short PROCESS_INPUT = 0;
- public static final short PROCESS_OUTPUT = 1;
- public static final short PROCESS_FAULT = 2;
- public static final short PARTNER_INPUT = 3;
- public static final short PARTNER_OUTPUT = 4;
- public static final short PARTNER_FAULT = 5;
- public static final short PARTNER_FAILURE = 6;
-
- private QName _portType;
- private String _operation;
- private String _mexId;
- private short _aspect;
-
- public ProcessMessageExchangeEvent() {}
-
- public ProcessMessageExchangeEvent(short aspect,
- QName processName,
- QName processId, Long processInstanceId) {
- super(processInstanceId);
- setProcessName(processName);
- setProcessId(processId);
- _aspect = aspect;
- }
-
- public short getAspect() {
- return _aspect;
- }
-
- /** Message exchange port type*/
- public QName getPortType() {
- return _portType;
- }
-
- /** Message exchange operation */
- public String getOperation() {
- return _operation;
- }
-
- /** Message exchange id */
- public String getMessageExchangeId() {
- return _mexId;
- }
-
- public void setAspect(short aspect) {
- _aspect = aspect;
- }
-
- public void setMexId(String mexId) {
- _mexId = mexId;
- }
-
- public void setOperation(String operation) {
- _operation = operation;
- }
-
- public void setPortType(QName portType) {
- _portType = portType;
- }
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.ode.bpel.evt;
+
+import javax.xml.namespace.QName;
+
+/**
+ *
+ */
+public class ProcessMessageExchangeEvent extends ProcessInstanceEvent {
+
+ private static final long serialVersionUID = 1L;
+
+ public static final short PROCESS_INPUT = 0;
+ public static final short PROCESS_OUTPUT = 1;
+ public static final short PROCESS_FAULT = 2;
+ public static final short PARTNER_INPUT = 3;
+ public static final short PARTNER_OUTPUT = 4;
+ public static final short PARTNER_FAULT = 5;
+ public static final short PARTNER_FAILURE = 6;
+
+ private QName _portType;
+ private String _operation;
+ private String _mexId;
+ private short _aspect;
+
+ public ProcessMessageExchangeEvent() {}
+
+ public ProcessMessageExchangeEvent(short aspect,
+ QName processName,
+ QName processId, Long processInstanceId) {
+ super(processInstanceId);
+ setProcessName(processName);
+ setProcessId(processId);
+ _aspect = aspect;
+ }
+
+ public short getAspect() {
+ return _aspect;
+ }
+
+ /** Message exchange port type*/
+ public QName getPortType() {
+ return _portType;
+ }
+
+ /** Message exchange operation */
+ public String getOperation() {
+ return _operation;
+ }
+
+ /** Message exchange id */
+ public String getMessageExchangeId() {
+ return _mexId;
+ }
+
+ public void setAspect(short aspect) {
+ _aspect = aspect;
+ }
+
+ public void setMexId(String mexId) {
+ _mexId = mexId;
+ }
+
+ public void setOperation(String operation) {
+ _operation = operation;
+ }
+
+ public void setPortType(QName portType) {
+ _portType = portType;
+ }
+}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessTerminationEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessTerminationEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessTerminationEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ProcessTerminationEvent.java Tue Feb 17 22:06:18 2009
@@ -1,34 +1,34 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.ode.bpel.evt;
-
-
-/**
- * Signals completion of the process.
- *
- */
-public class ProcessTerminationEvent extends ProcessInstanceEvent {
-
- private static final long serialVersionUID = -5197228186952515826L;
-
- public ProcessTerminationEvent() {
- super();
- }
-
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.ode.bpel.evt;
+
+
+/**
+ * Signals completion of the process.
+ *
+ */
+public class ProcessTerminationEvent extends ProcessInstanceEvent {
+
+ private static final long serialVersionUID = -5197228186952515826L;
+
+ public ProcessTerminationEvent() {
+ super();
+ }
+
+}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeCompletionEvent.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/evt/ScopeFaultEvent.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/ConfigurationException.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/ConfigurationException.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/ConfigurationException.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/ConfigurationException.java Tue Feb 17 22:06:18 2009
@@ -26,10 +26,10 @@
*/
public class ConfigurationException extends Exception {
- private static final long serialVersionUID = -4815181439145449891L;
+ private static final long serialVersionUID = -4815181439145449891L;
- public ConfigurationException(String msg, Throwable cause) {
- super(msg, cause);
- }
+ public ConfigurationException(String msg, Throwable cause) {
+ super(msg, cause);
+ }
}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/EvaluationContext.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/EvaluationContext.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/EvaluationContext.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/explang/EvaluationContext.java Tue Feb 17 22:06:18 2009
@@ -102,18 +102,18 @@
*/
boolean narrowTypes();
- /**
- * Retrieves the base URI that the BPEL Process execution contextis running relative to.
- *
- * @return URI - the URI representing the absolute physical file path location that this process is defined within.
- */
- URI getBaseResourceURI();
-
- /**
- * Retrieves the property value that has been defined for this BPEL Process type.
- *
- * @return propertyValue - the value corresponding to the process property name.
- */
- Node getPropertyValue(QName propertyName);
+ /**
+ * Retrieves the base URI that the BPEL Process execution contextis running relative to.
+ *
+ * @return URI - the URI representing the absolute physical file path location that this process is defined within.
+ */
+ URI getBaseResourceURI();
+
+ /**
+ * Retrieves the property value that has been defined for this BPEL Process type.
+ *
+ * @return propertyValue - the value corresponding to the process property name.
+ */
+ Node getPropertyValue(QName propertyName);
}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/BpelEventListener.java Tue Feb 17 22:06:18 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/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/ProcessConf.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/ProcessConf.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/ProcessConf.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/iapi/ProcessConf.java Tue Feb 17 22:06:18 2009
@@ -172,14 +172,14 @@
Set<CLEANUP_CATEGORY> getCleanupCategories(boolean instanceSucceeded);
public enum CLEANUP_CATEGORY {
- INSTANCE,
- VARIABLES,
- MESSAGES,
- CORRELATIONS,
- EVENTS;
-
- public static CLEANUP_CATEGORY fromString(String lowerCase) {
- return valueOf(CLEANUP_CATEGORY.class, lowerCase.toUpperCase());
- }
- }
+ INSTANCE,
+ VARIABLES,
+ MESSAGES,
+ CORRELATIONS,
+ EVENTS;
+
+ public static CLEANUP_CATEGORY fromString(String lowerCase) {
+ return valueOf(CLEANUP_CATEGORY.class, lowerCase.toUpperCase());
+ }
+ }
}
Modified: ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java?rev=745271&r1=745270&r2=745271&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-api/src/main/java/org/apache/ode/bpel/jmx/BpelEventNotification.java Tue Feb 17 22:06:18 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();
+ }
}