summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk/modules/core-spi/src/main/java/org/apache/tuscany/sca/invocation/InterceptorAsync.java
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--sca-java-2.x/trunk/modules/core-spi/src/main/java/org/apache/tuscany/sca/invocation/InterceptorAsync.java26
1 files changed, 23 insertions, 3 deletions
diff --git a/sca-java-2.x/trunk/modules/core-spi/src/main/java/org/apache/tuscany/sca/invocation/InterceptorAsync.java b/sca-java-2.x/trunk/modules/core-spi/src/main/java/org/apache/tuscany/sca/invocation/InterceptorAsync.java
index 806feccca2..f29dfddf6a 100644
--- a/sca-java-2.x/trunk/modules/core-spi/src/main/java/org/apache/tuscany/sca/invocation/InterceptorAsync.java
+++ b/sca-java-2.x/trunk/modules/core-spi/src/main/java/org/apache/tuscany/sca/invocation/InterceptorAsync.java
@@ -47,16 +47,36 @@ public interface InterceptorAsync extends Interceptor, InvokerAsyncRequest, Invo
*
*/
Message processRequest(Message msg);
+
+ /**
+ * Post processing for a request message. Intended to be called after
+ * the invocation of the request chain returns, to permit cleanup/error handling
+ * if required
+ * @param msg The request Message
+ * @return the processed message
+ */
+ Message postProcessRequest(Message msg);
+
+ /**
+ * Post processing for a request message where an exception was thrown.
+ * Intended to be called after the invocation of the request chain returns,
+ * to permit cleanup/error handling if required
+ * @param msg The request Message
+ * @param e a Thowable which is some form of exception thrown during the processing
+ * of the request message by the invocation chain
+ * @return the processed message
+ */
+ Message postProcessRequest(Message msg, Throwable e) throws Throwable;
/**
* Process a response message. Provided so that the synchronous
* and asynchronous patterns can re-use the response message
* processing
*
- * @param msg The request Message
+ * @param msg The response Message
* @return the processed message
*
*/
Message processResponse(Message msg);
-
-}
+
+} // end interface InterceptorAsync