You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by ms...@apache.org on 2007/08/06 22:48:02 UTC
svn commit: r563268 -
/ode/branches/bart/bpel-api/src/main/java/org/apache/ode/bpel/iapi/MessageExchange.java
Author: mszefler
Date: Mon Aug 6 13:48:02 2007
New Revision: 563268
URL: http://svn.apache.org/viewvc?view=rev&rev=563268
Log:
BART, some additinal refactorings. New model to fix concurrency problems in Partner invokes.
Modified:
ode/branches/bart/bpel-api/src/main/java/org/apache/ode/bpel/iapi/MessageExchange.java
Modified: ode/branches/bart/bpel-api/src/main/java/org/apache/ode/bpel/iapi/MessageExchange.java
URL: http://svn.apache.org/viewvc/ode/branches/bart/bpel-api/src/main/java/org/apache/ode/bpel/iapi/MessageExchange.java?view=diff&rev=563268&r1=563267&r2=563268
==============================================================================
--- ode/branches/bart/bpel-api/src/main/java/org/apache/ode/bpel/iapi/MessageExchange.java (original)
+++ ode/branches/bart/bpel-api/src/main/java/org/apache/ode/bpel/iapi/MessageExchange.java Mon Aug 6 13:48:02 2007
@@ -47,34 +47,24 @@
/** New message exchange, has not been "invoked" */
NEW,
- /** The request is being sent to the "server" */
- REQUEST,
+ /** The request was sent. */
+ REQ,
- /** Waiting for an asynchronous response from the "server" */
- ASYNC,
+ /** The acknowledgement (either response/fault/failure) was sent. */
+ ACK,
- /** The one way request has been sent to the server. */
- // ONE_WAY, - supported as ASYNC + getMessageExchangePatter() - See JIRA ODE-54
+ /** The acknowledgement was processed. */
+ COMPLETED
- /** Processing the response received from the "server". */
- RESPONSE,
+ }
- /** Processing the fault received from the "server". */
+ public enum AckType {
+ RESPONSE,
+ ONEWAY,
FAULT,
-
- /** Processing a failure. */
- FAILURE,
-
- /** Message exchange completed succesfully. */
- COMPLETED_OK,
-
- /** Message exchange completed with a fault. */
- COMPLETED_FAULT,
-
- /** Message exchange completed with a failure. */
- COMPLETED_FAILURE,
+ FAILURE
}
-
+
/**
* Enumeration of the types of failures.
*/
@@ -143,6 +133,7 @@
throws BpelEngineException;
+ AckType getAckType();
/**
* Return the type of message-exchange that resulted form this invocation