svn commit: r1063280 - in /tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider: DelegatingSCAServiceBindingProvider.java RuntimeSCAServiceBindingProvider.java

[sl...@apache.org]

Author: slaws
Date: Tue Jan 25 13:50:45 2011
New Revision: 1063280

URL: http://svn.apache.org/viewvc?rev=1063280&view=rev
Log:
Delegate the creation of the response invoker if there is a delegate present. 

Modified:
    tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAServiceBindingProvider.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/DelegatingSCAServiceBindingProvider.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/DelegatingSCAServiceBindingProvider.java?rev=1063280&r1=1063279&r2=1063280&view=diff
==============================================================================
--- tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAServiceBindingProvider.java (original)
+++ tuscany/sca-java-2.x/trunk/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAServiceBindingProvider.java Tue Jan 25 13:50:45 2011
@@ -22,6 +22,9 @@ package org.apache.tuscany.sca.binding.s
 import java.util.logging.Logger;
 
 import org.apache.tuscany.sca.interfacedef.InterfaceContract;
+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.RuntimeEndpoint;
 
@@ -31,7 +34,7 @@ import org.apache.tuscany.sca.runtime.Ru
  *
  * @version $Rev$ $Date$
  */
-public class DelegatingSCAServiceBindingProvider implements ServiceBindingProvider {
+public class DelegatingSCAServiceBindingProvider implements EndpointAsyncProvider {
 
     private static final Logger logger = Logger.getLogger(DelegatingSCAServiceBindingProvider.class.getName());
 
@@ -49,13 +52,40 @@ public class DelegatingSCAServiceBinding
 
     }
 
+    @Override
     public InterfaceContract getBindingInterfaceContract() {
         return provider.getBindingInterfaceContract();
     }
 
+    @Override
     public boolean supportsOneWayInvocation() {
         return provider.supportsOneWayInvocation();
     }
+    
+    @Override
+    public void configure() {  
+        if (provider instanceof EndpointProvider){
+            ((EndpointProvider)provider).configure();
+        }
+    }    
+    
+    @Override
+    public boolean supportsNativeAsync() {
+        if (provider instanceof EndpointAsyncProvider){
+            return ((EndpointAsyncProvider)provider).supportsNativeAsync();
+        } else {
+            return false;
+        }
+    }
+    
+    @Override
+    public InvokerAsyncResponse createAsyncResponseInvoker() {
+        if (provider instanceof EndpointAsyncProvider){
+            return ((EndpointAsyncProvider)provider).createAsyncResponseInvoker();
+        } else {
+            return null;
+        }
+    }
 
     public void start() {
         if (started) {

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=1063280&r1=1063279&r2=1063280&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 Tue Jan 25 13:50:45 2011
@@ -115,7 +115,11 @@ public class RuntimeSCAServiceBindingPro
     }
     
     public InvokerAsyncResponse createAsyncResponseInvoker() {
-        return new SCABindingAsyncResponseInvoker(null, null);
+        if (distributedProvider != null) {
+            return ((EndpointAsyncProvider)distributedProvider).createAsyncResponseInvoker();
+        } else {
+            return new SCABindingAsyncResponseInvoker(null, null);
+        }
     }
 
     /**