From 1c92473c0cfa75339884087de096c0feed1378c5 Mon Sep 17 00:00:00 2001 From: slaws Date: Tue, 7 Dec 2010 22:05:44 +0000 Subject: TUSCANY-3801 - missed files from previous check in. git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1043211 13f79535-47bb-0310-9956-ffa450edef68 --- .../provider/RuntimeSCAServiceBindingProvider.java | 6 ++---- .../sca/provider/SCABindingAsyncResponseInvoker.java | 19 ++++++++++--------- .../sca/binding/sca/provider/SCABindingInvoker.java | 4 ++++ 3 files changed, 16 insertions(+), 13 deletions(-) (limited to 'sca-java-2.x/trunk/modules/binding-sca-runtime/src/main') diff --git a/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java b/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java index 87d3013a98..fd04cf02e3 100644 --- a/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java +++ b/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java @@ -22,10 +22,8 @@ package org.apache.tuscany.sca.binding.sca.provider; import org.apache.tuscany.sca.core.ExtensionPointRegistry; import org.apache.tuscany.sca.core.UtilityExtensionPoint; import org.apache.tuscany.sca.interfacedef.InterfaceContract; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Invoker; +import org.apache.tuscany.sca.invocation.InvokerAsyncResponse; import org.apache.tuscany.sca.provider.EndpointAsyncProvider; -import org.apache.tuscany.sca.provider.EndpointProvider; import org.apache.tuscany.sca.provider.ServiceBindingProvider; import org.apache.tuscany.sca.runtime.RuntimeComponentService; import org.apache.tuscany.sca.runtime.RuntimeEndpoint; @@ -110,7 +108,7 @@ public class RuntimeSCAServiceBindingProvider implements EndpointAsyncProvider { return true; } - public Invoker createAsyncResponseInvoker(Operation operation) { + public InvokerAsyncResponse createAsyncResponseInvoker() { return new SCABindingAsyncResponseInvoker(null, null); } diff --git a/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingAsyncResponseInvoker.java b/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingAsyncResponseInvoker.java index 26707e8ebd..d502cdd22c 100644 --- a/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingAsyncResponseInvoker.java +++ b/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingAsyncResponseInvoker.java @@ -20,26 +20,27 @@ package org.apache.tuscany.sca.binding.sca.provider; import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Interceptor; -import org.apache.tuscany.sca.invocation.InvocationChain; -import org.apache.tuscany.sca.invocation.Invoker; +import org.apache.tuscany.sca.invocation.InvokerAsyncResponse; import org.apache.tuscany.sca.invocation.Message; import org.apache.tuscany.sca.runtime.RuntimeEndpointReference; /** * @version $Rev: 989157 $ $Date: 2010-08-25 16:02:01 +0100 (Wed, 25 Aug 2010) $ */ -public class SCABindingAsyncResponseInvoker implements Invoker { +public class SCABindingAsyncResponseInvoker implements InvokerAsyncResponse { public SCABindingAsyncResponseInvoker(ExtensionPointRegistry extensionPoints, RuntimeEndpointReference endpointReference) { } - + // TODO - this only works for the local case! - public Message invoke(Message msg) { + public void invokeAsyncResponse(Message msg) { RuntimeEndpointReference epr = (RuntimeEndpointReference)msg.getFrom(); - epr.invokeAsyncResponse(msg); + epr.invokeAsyncResponse(msg); + } + + public Message processResponse(Message msg) { + // TODO Auto-generated method stub return null; } -} +} \ No newline at end of file diff --git a/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingInvoker.java b/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingInvoker.java index 95fd4cd934..a131c88a0c 100644 --- a/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingInvoker.java +++ b/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingInvoker.java @@ -99,5 +99,9 @@ public class SCABindingInvoker extends InterceptorAsyncImpl { return msg; } + + public boolean isLocalSCABIndingInvoker() { + return true; + } } -- cgit v1.2.3