Return-Path: Delivered-To: apmail-tuscany-commits-archive@www.apache.org Received: (qmail 45150 invoked from network); 3 Dec 2010 15:19:21 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 3 Dec 2010 15:19:21 -0000 Received: (qmail 89183 invoked by uid 500); 3 Dec 2010 15:19:20 -0000 Delivered-To: apmail-tuscany-commits-archive@tuscany.apache.org Received: (qmail 88630 invoked by uid 500); 3 Dec 2010 15:19:20 -0000 Mailing-List: contact commits-help@tuscany.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@tuscany.apache.org Delivered-To: mailing list commits@tuscany.apache.org Received: (qmail 88621 invoked by uid 99); 3 Dec 2010 15:19:19 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Dec 2010 15:19:19 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED,FSL_RU_URL X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Dec 2010 15:19:18 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 19D6E23889D7; Fri, 3 Dec 2010 15:17:42 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1041863 - in /tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider: RuntimeSCAReferenceBindingProvider.java RuntimeSCAServiceBindingProvider.java Date: Fri, 03 Dec 2010 15:17:42 -0000 To: commits@tuscany.apache.org From: slaws@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20101203151742.19D6E23889D7@eris.apache.org> Author: slaws Date: Fri Dec 3 15:17:41 2010 New Revision: 1041863 URL: http://svn.apache.org/viewvc?rev=1041863&view=rev Log: TUSCANY-3801 - Move the SCA binding up to the new async provider interfaces. Modified: tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java Modified: tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java?rev=1041863&r1=1041862&r2=1041863&view=diff ============================================================================== --- tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java (original) +++ tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java Fri Dec 3 15:17:41 2010 @@ -30,6 +30,7 @@ import org.apache.tuscany.sca.interfaced import org.apache.tuscany.sca.interfacedef.Operation; import org.apache.tuscany.sca.invocation.InvocationChain; import org.apache.tuscany.sca.invocation.Invoker; +import org.apache.tuscany.sca.provider.EndpointReferenceAsyncProvider; import org.apache.tuscany.sca.provider.EndpointReferenceProvider; import org.apache.tuscany.sca.provider.ReferenceBindingProvider; import org.apache.tuscany.sca.runtime.RuntimeComponent; @@ -49,7 +50,7 @@ import org.oasisopen.sca.ServiceUnavaila * * @version $Rev$ $Date$ */ -public class RuntimeSCAReferenceBindingProvider implements EndpointReferenceProvider { +public class RuntimeSCAReferenceBindingProvider implements EndpointReferenceAsyncProvider { private RuntimeEndpointReference endpointReference; private RuntimeComponent component; @@ -209,7 +210,10 @@ public class RuntimeSCAReferenceBindingP if (distributedProvider instanceof EndpointReferenceProvider) { ((EndpointReferenceProvider)distributedProvider).configure(); } - + } + + public boolean supportsNativeAsync() { + return true; } } Modified: tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java?rev=1041863&r1=1041862&r2=1041863&view=diff ============================================================================== --- tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java (original) +++ tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java Fri Dec 3 15:17:41 2010 @@ -22,6 +22,10 @@ package org.apache.tuscany.sca.binding.s 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.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; @@ -34,7 +38,7 @@ import org.apache.tuscany.sca.runtime.Ru * * @version $Rev$ $Date$ */ -public class RuntimeSCAServiceBindingProvider implements ServiceBindingProvider { +public class RuntimeSCAServiceBindingProvider implements EndpointAsyncProvider { private RuntimeEndpoint endpoint; private RuntimeComponentService service; @@ -98,4 +102,16 @@ public class RuntimeSCAServiceBindingPro } } + public void configure() { + // TODO Auto-generated method stub + } + + public boolean supportsNativeAsync() { + return true; + } + + public Invoker createAsyncResponseInvoker(Operation operation) { + return new SCABindingAsyncResponseInvoker(null, null); + } + }