summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk/modules/implementation-java-runtime
diff options
context:
space:
mode:
authoredwardsmj <edwardsmj@13f79535-47bb-0310-9956-ffa450edef68>2011-01-24 14:57:26 +0000
committeredwardsmj <edwardsmj@13f79535-47bb-0310-9956-ffa450edef68>2011-01-24 14:57:26 +0000
commit0232f3394601df2306b87b78cbf53e873ca74d78 (patch)
treeb1e480aa3c9e16ae3d02d3a1540a92c65632ebc8 /sca-java-2.x/trunk/modules/implementation-java-runtime
parentd80d0ef30325d00d959ef0795b22b16fdf702008 (diff)
Fixing serialization of AsyncResponseInvoker in support of async services under TUSCANY-3783
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1062814 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/trunk/modules/implementation-java-runtime')
-rw-r--r--sca-java-2.x/trunk/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/ResponseDispatchImpl.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/sca-java-2.x/trunk/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/ResponseDispatchImpl.java b/sca-java-2.x/trunk/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/ResponseDispatchImpl.java
index 53dc708a30..343682d8b1 100644
--- a/sca-java-2.x/trunk/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/ResponseDispatchImpl.java
+++ b/sca-java-2.x/trunk/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/ResponseDispatchImpl.java
@@ -138,7 +138,7 @@ public class ResponseDispatchImpl<T> implements ResponseDispatch<T>, Serializabl
// Use response invoker if present
if( respInvoker != null ) {
//respInvoker.invokeAsyncResponse(new AsyncFaultWrapper(e));
- respInvoker.invokeAsyncResponse(e);
+ respInvoker.invokeAsyncResponse(e, null);
return;
} // end if
@@ -153,6 +153,7 @@ public class ResponseDispatchImpl<T> implements ResponseDispatch<T>, Serializabl
* @throws IllegalStateException if either the sendResponse method or the sendFault method have been called previously
* @param res - the response message, which is of type T
*/
+ @SuppressWarnings("unchecked")
public void sendResponse(T res) {
if( sendOK() ) {
lock.lock();
@@ -175,7 +176,7 @@ public class ResponseDispatchImpl<T> implements ResponseDispatch<T>, Serializabl
// Use response invoker if present
if( respInvoker != null ) {
- respInvoker.invokeAsyncResponse(res);
+ respInvoker.invokeAsyncResponse(res, null);
return;
} // end if
} // end method sendResponse