diff options
author | slaws <slaws@13f79535-47bb-0310-9956-ffa450edef68> | 2010-12-13 11:18:55 +0000 |
---|---|---|
committer | slaws <slaws@13f79535-47bb-0310-9956-ffa450edef68> | 2010-12-13 11:18:55 +0000 |
commit | 808061b072eb07e33b4ae12a01d42efdbc225e9a (patch) | |
tree | e1832edd7474f1acef8647c798a8235d816c3e6f /sca-java-2.x/trunk/modules | |
parent | 4174b0fa7cbd6cffa801897b3a9f48ee6280c571 (diff) |
TUSCANY-3801 - reorder code so that the RuntimeInvoker does not take part in the async response "previous" chain
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1045068 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/trunk/modules')
-rw-r--r-- | sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointImpl.java | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointImpl.java b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointImpl.java index bdacdda53b..2d87e50ed0 100644 --- a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointImpl.java +++ b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointImpl.java @@ -605,13 +605,10 @@ public class RuntimeEndpointImpl extends EndpointImpl implements RuntimeEndpoint } } - - // Add the runtime invoker to the end of the binding chain. - // It mediates between the binding chain and selects the - // correct invocation chain based on the operation that's - // been selected - bindingInvocationChain.addInvoker(invoker); + // This is strategically placed before the RuntimeInvoker is added to the end of the + // binding chain as the RuntimeInvoker doesn't need to take part in the response + // processing and doesn't implement InvokerAsyncResponse if (isAsyncInvocation()){ // fix up the invocation chains to point back to the // binding chain so that async response messages @@ -641,6 +638,12 @@ public class RuntimeEndpointImpl extends EndpointImpl implements RuntimeEndpoint //TODO - throw error once the old async code is removed } } + + // Add the runtime invoker to the end of the binding chain. + // It mediates between the binding chain and selects the + // correct invocation chain based on the operation that's + // been selected + bindingInvocationChain.addInvoker(invoker); } /** |