diff options
author | edwardsmj <edwardsmj@13f79535-47bb-0310-9956-ffa450edef68> | 2011-01-24 14:57:26 +0000 |
---|---|---|
committer | edwardsmj <edwardsmj@13f79535-47bb-0310-9956-ffa450edef68> | 2011-01-24 14:57:26 +0000 |
commit | 0232f3394601df2306b87b78cbf53e873ca74d78 (patch) | |
tree | b1e480aa3c9e16ae3d02d3a1540a92c65632ebc8 /sca-java-2.x/trunk/modules/implementation-java-runtime | |
parent | d80d0ef30325d00d959ef0795b22b16fdf702008 (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.java | 5 |
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 |