Copy trunk to beta2 release branch. (I've not yet changed the version so that would need to be done first before the branch is used)

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1069272 13f79535-47bb-0310-9956-ffa450edef68

10 files changed, 1227 insertions, 0 deletions

diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DefaultSCABindingMapper.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DefaultSCABindingMapper.java
new file mode 100644
index 0000000000..5219cab15d
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DefaultSCABindingMapper.java
@@ -0,0 +1,242 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+import java.io.StringReader;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.logging.Logger;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+
+import org.apache.tuscany.sca.assembly.Base;
+import org.apache.tuscany.sca.assembly.Binding;
+import org.apache.tuscany.sca.assembly.builder.BindingBuilder;
+import org.apache.tuscany.sca.assembly.builder.BuilderContext;
+import org.apache.tuscany.sca.assembly.builder.BuilderExtensionPoint;
+import org.apache.tuscany.sca.common.xml.stax.StAXHelper;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessorExtensionPoint;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.extensibility.ServiceDeclarationParser;
+import org.apache.tuscany.sca.policy.PolicySubject;
+import org.apache.tuscany.sca.provider.ProviderFactory;
+import org.apache.tuscany.sca.provider.ProviderFactoryExtensionPoint;
+import org.apache.tuscany.sca.runtime.DomainRegistryFactory;
+import org.apache.tuscany.sca.runtime.DomainRegistryFactoryExtensionPoint;
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+import org.oasisopen.sca.ServiceRuntimeException;
+
+/**
+ * Default implementation of SCABindingMapper
+ */
+public class DefaultSCABindingMapper implements SCABindingMapper {
+    private final static Logger logger = Logger.getLogger(DefaultSCABindingMapper.class.getName());
+    protected ExtensionPointRegistry registry;
+    protected ProviderFactoryExtensionPoint providerFactories;
+    protected StAXArtifactProcessorExtensionPoint processors;
+    protected QName defaultMappedBinding;
+
+    public DefaultSCABindingMapper(ExtensionPointRegistry registry, Map<String, String> attributes) {
+        this.registry = registry;
+        providerFactories = registry.getExtensionPoint(ProviderFactoryExtensionPoint.class);
+        processors = registry.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class);
+        defaultMappedBinding = getDefaultMappedBinding(attributes);
+    }
+
+    protected QName getDefaultMappedBinding(Map<String, String> attributes) {
+        QName defaultMappedBinding = null;
+        if (attributes != null) {
+            String qname = attributes.get("mappedBinding");
+            if (qname != null) {
+                defaultMappedBinding = ServiceDeclarationParser.getQName(qname);
+            }
+        }
+        if (defaultMappedBinding == null) {
+            String qname =
+                System.getProperty("org.apache.tuscany.sca.binding.sca.provider.SCABindingMapper.mappedBinding");
+            if (qname != null) {
+                defaultMappedBinding = ServiceDeclarationParser.getQName(qname);
+            } else {
+                // By default, mapping to binding.ws or if thats not available then binding.rmi
+                defaultMappedBinding = new QName(Base.SCA11_TUSCANY_NS, "binding.hazelcast");
+                if (registry.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class).getProcessor(defaultMappedBinding) == null) {
+                    defaultMappedBinding = new QName(Base.SCA11_NS, "binding.ws");
+                    if (registry.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class).getProcessor(defaultMappedBinding) == null) {
+                        defaultMappedBinding = new QName(Base.SCA11_TUSCANY_NS, "binding.rmi");
+                    }
+                }
+            }
+        }
+        return defaultMappedBinding;
+    }
+
+    private BindingBuilder getBindingBuilder(QName binding) {
+        StAXArtifactProcessor processor = processors.getProcessor(binding);
+        if (processor == null) {
+            logger.warning("Mapped binding for binding.sca is not supported: " + binding);
+        }
+
+        try {
+            if (processor != null) {
+                Binding bindingTemplate = createDelegatingBinding(binding);
+                ProviderFactory providerFactory = providerFactories.getProviderFactory(bindingTemplate.getClass());
+                if (providerFactory == null) {
+                    logger.warning("Mapped binding for binding.sca is not supported: " + binding);
+                    processor = null;
+                }
+            }
+        } catch (Throwable e) {
+            throw new ServiceRuntimeException(e);
+        }
+        BuilderExtensionPoint builders = registry.getExtensionPoint(BuilderExtensionPoint.class);
+        BindingBuilder builder = builders.getBindingBuilder(binding);
+        return builder;
+    }
+
+    // FIXME: [rfeng] This is a HACK to check if we should make binding.sca remotable
+    // by checking if we have distributed domain registry present
+    protected boolean isDistributed() {
+        DomainRegistryFactoryExtensionPoint factories =
+            registry.getExtensionPoint(DomainRegistryFactoryExtensionPoint.class);
+        List<DomainRegistryFactory> list = factories.getDomainRegistryFactories();
+        if (list.size() == 1) {
+            String[] schemes = list.get(0).getSupportedSchemes();
+            if (Arrays.asList(schemes).contains("local")) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    public RuntimeEndpoint map(RuntimeEndpoint endpoint) {
+        
+        QName bindingType = chooseBinding(endpoint);
+        if (processors.getProcessor(bindingType) == null) {
+            logger.warning("Mapped binding for binding.sca is not supported: " + bindingType);
+            return null;
+        }
+        
+        // create a copy of the endpoint  but with the web service binding in
+        RuntimeEndpoint ep = null;
+        try {
+            ep = (RuntimeEndpoint)endpoint.clone();
+        } catch (Exception ex) {
+            // we know we can clone endpoint references
+        }
+
+        Binding binding = map(endpoint.getBinding(), bindingType);
+        ep.setBinding(binding);
+        BindingBuilder builder = getBindingBuilder(bindingType);
+        if (builder != null) {
+            builder.build(ep.getComponent(), ep.getService(), binding, new BuilderContext(registry), false);
+        }
+        return ep;
+    }
+
+    public RuntimeEndpointReference map(RuntimeEndpointReference endpointReference) {
+        QName bindingType = chooseBinding(endpointReference);
+        if (processors.getProcessor(bindingType) == null) {
+            logger.warning("Mapped binding for binding.sca is not supported: " + bindingType);
+            return null;
+        }
+        
+        // create a copy of the endpoint  but with the web service binding in
+        RuntimeEndpointReference epr = null;
+        try {
+            epr = (RuntimeEndpointReference)endpointReference.clone();
+        } catch (Exception ex) {
+            // we know we can clone endpoint references
+        }
+
+        Binding binding = map(endpointReference.getBinding(), bindingType);
+        epr.setBinding(binding);
+
+        // epr.setTargetEndpoint(map((RuntimeEndpoint)epr.getTargetEndpoint()));
+
+        BindingBuilder builder = getBindingBuilder(bindingType);
+        if (builder != null) {
+            builder.build(epr.getComponent(), epr.getReference(), binding, new BuilderContext(registry), false);
+        }
+
+        return epr;
+    }
+
+    protected Binding map(Binding scaBinding, QName newBindingType) {
+        try {
+            Binding binding = createDelegatingBinding(newBindingType);
+            binding.setName(scaBinding.getName());
+            binding.setURI(scaBinding.getURI());
+            binding.setOperationSelector(scaBinding.getOperationSelector());
+            binding.setRequestWireFormat(scaBinding.getRequestWireFormat());
+            binding.setResponseWireFormat(scaBinding.getResponseWireFormat());
+            if (binding instanceof PolicySubject && scaBinding instanceof PolicySubject) {
+                PolicySubject subject1 = (PolicySubject)binding;
+                PolicySubject subject2 = (PolicySubject)scaBinding;
+                subject1.getPolicySets().addAll(subject2.getPolicySets());
+                subject1.getRequiredIntents().addAll(subject2.getRequiredIntents());
+            }
+            return binding;
+        } catch (Throwable e) {
+            throw new ServiceRuntimeException(e);
+        }
+
+    }
+    
+    protected Binding createDelegatingBinding(QName bindingType) throws XMLStreamException, ContributionReadException {
+        StAXArtifactProcessor processor = processors.getProcessor(bindingType);
+        if (processor == null) {
+            logger.warning("Mapped binding for binding.sca is not supported: " + bindingType);
+        }
+
+        StringBuffer xml = new StringBuffer();
+        xml.append("<").append(bindingType.getLocalPart()).append(" xmlns:b=\"").append(bindingType.getNamespaceURI()).append("\"/>");
+
+        StAXHelper staxHelper = StAXHelper.getInstance(registry);
+        XMLStreamReader reader = staxHelper.createXMLStreamReader(new StringReader(xml.toString()));
+        reader.nextTag();
+        Binding binding = (Binding)processor.read(reader, new ProcessorContext(registry));
+        
+        return binding;
+    }
+
+    public boolean isRemotable(RuntimeEndpoint endpoint) {
+        return isDistributed() && processors.getProcessor(chooseBinding(endpoint)) != null;
+    }
+
+    public boolean isRemotable(RuntimeEndpointReference endpointReference) {
+        return isDistributed() && processors.getProcessor(chooseBinding(endpointReference)) != null;
+    }
+
+    protected QName chooseBinding(RuntimeEndpoint endpoint) {
+        return defaultMappedBinding;
+    }
+
+    protected QName chooseBinding(RuntimeEndpointReference endpointReference) {
+        return defaultMappedBinding;
+    }
+
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAReferenceBindingProvider.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAReferenceBindingProvider.java
new file mode 100644
index 0000000000..a8fec07f5c
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAReferenceBindingProvider.java
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+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.EndpointReferenceProvider;
+import org.apache.tuscany.sca.provider.ReferenceBindingProvider;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+
+/**
+ * The reference binding provider for the remote sca binding implementation. 
+ */
+public class DelegatingSCAReferenceBindingProvider implements EndpointReferenceProvider {
+
+    private ReferenceBindingProvider provider;
+
+    public DelegatingSCAReferenceBindingProvider(RuntimeEndpointReference endpointReference,
+                                                 SCABindingMapper mapper) {
+        RuntimeEndpointReference epr = mapper.map(endpointReference);
+        if (epr != null) {
+            provider = epr.getBindingProvider();
+        }
+    }
+
+    public InterfaceContract getBindingInterfaceContract() {
+        return provider.getBindingInterfaceContract();
+    }
+
+    public boolean supportsOneWayInvocation() {
+        return provider.supportsOneWayInvocation();
+    }
+
+    public Invoker createInvoker(Operation operation) {
+        return provider.createInvoker(operation);
+    }
+
+    public void start() {
+        provider.start();
+    }
+
+    public void stop() {
+        provider.stop();
+    }
+
+    public void configure() {
+        if (provider instanceof EndpointReferenceProvider) {
+            ((EndpointReferenceProvider)provider).configure();
+        }
+    }
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAServiceBindingProvider.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAServiceBindingProvider.java
new file mode 100644
index 0000000000..ea888f4f8e
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/DelegatingSCAServiceBindingProvider.java
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+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;
+
+/**
+ * The service binding provider for the remote sca binding implementation. Relies on the
+ * binding-ws-axis implementation for providing a remote message endpoint
+ *
+ * @version $Rev$ $Date$
+ */
+public class DelegatingSCAServiceBindingProvider implements EndpointAsyncProvider {
+
+    private static final Logger logger = Logger.getLogger(DelegatingSCAServiceBindingProvider.class.getName());
+
+    private ServiceBindingProvider provider;
+    private RuntimeEndpoint endpoint;
+    private RuntimeEndpoint mappedEndpoint;
+    private boolean started = false;
+
+    public DelegatingSCAServiceBindingProvider(RuntimeEndpoint endpoint, SCABindingMapper mapper) {
+        this.endpoint = endpoint;
+        this.mappedEndpoint = mapper.map(endpoint);
+        if (mappedEndpoint != null) {
+            provider = mappedEndpoint.getBindingProvider();
+        }
+
+    }
+
+    @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) {
+            return;
+        } else {
+            provider.start();
+            // Set the resolved binding URI back to the binding.sca
+            endpoint.getBinding().setURI(mappedEndpoint.getBinding().getURI());
+            started = true;
+        }
+    }
+
+    public void stop() {
+        if (!started) {
+            return;
+        }
+        try {
+            provider.stop();
+        } finally {
+            started = false;
+        }
+    }
+
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCABindingProviderFactory.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCABindingProviderFactory.java
new file mode 100644
index 0000000000..75d8de64ca
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCABindingProviderFactory.java
@@ -0,0 +1,54 @@
+/*
+ah * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+import org.apache.tuscany.sca.assembly.SCABinding;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.provider.BindingProviderFactory;
+import org.apache.tuscany.sca.provider.ReferenceBindingProvider;
+import org.apache.tuscany.sca.provider.ServiceBindingProvider;
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+
+/**
+ * The factory for creating SCA Binding providers
+ * 
+ * @version $Rev$ $Date$
+ */
+public class RuntimeSCABindingProviderFactory implements BindingProviderFactory<SCABinding> {
+    
+    private ExtensionPointRegistry extensionPoints;
+    
+    public RuntimeSCABindingProviderFactory(ExtensionPointRegistry extensionPoints) {
+        this.extensionPoints = extensionPoints; 
+    } 
+    
+    public ReferenceBindingProvider createReferenceBindingProvider(RuntimeEndpointReference endpointReference) {
+        return  new RuntimeSCAReferenceBindingProvider(extensionPoints, endpointReference);
+    }
+
+    public ServiceBindingProvider createServiceBindingProvider(RuntimeEndpoint endpoint) {
+        return new RuntimeSCAServiceBindingProvider(extensionPoints, endpoint);
+    }
+
+    public Class<SCABinding> getModelType() {
+        return SCABinding.class;
+    }
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java
new file mode 100644
index 0000000000..36ae886b46
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAReferenceBindingProvider.java
@@ -0,0 +1,224 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+import org.apache.tuscany.sca.assembly.Endpoint;
+import org.apache.tuscany.sca.assembly.Reference;
+import org.apache.tuscany.sca.assembly.SCABinding;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
+import org.apache.tuscany.sca.databinding.Mediator;
+import org.apache.tuscany.sca.interfacedef.Compatibility;
+import org.apache.tuscany.sca.interfacedef.InterfaceContract;
+import org.apache.tuscany.sca.interfacedef.InterfaceContractMapper;
+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;
+import org.apache.tuscany.sca.runtime.RuntimeComponentReference;
+import org.apache.tuscany.sca.runtime.RuntimeComponentService;
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+import org.oasisopen.sca.ServiceRuntimeException;
+import org.oasisopen.sca.ServiceUnavailableException;
+
+/**
+ * The sca reference binding provider mediates between the twin requirements of
+ * local sca bindings and remote sca bindings. In the local case is does
+ * very little. When the sca binding model is set as being remote (because a
+ * reference target can't be resolved in the current model) this binding will
+ * try and create a remote connection to it
+ *
+ * @version $Rev$ $Date$
+ */
+public class RuntimeSCAReferenceBindingProvider implements EndpointReferenceAsyncProvider {
+
+    private RuntimeEndpointReference endpointReference;
+    private RuntimeComponent component;
+    private RuntimeComponentReference reference;
+    private SCABinding binding;
+    private boolean remotable;
+    private boolean started = false;
+
+    private ReferenceBindingProvider distributedProvider;
+    private Mediator mediator;
+    private InterfaceContractMapper interfaceContractMapper;
+    private SCABindingMapper scaBindingMapper;
+    private ExtensionPointRegistry registry;
+
+    public RuntimeSCAReferenceBindingProvider(ExtensionPointRegistry extensionPoints,
+                                              RuntimeEndpointReference endpointReference) {
+        this.registry = extensionPoints;
+    	this.endpointReference = endpointReference;
+        this.component = (RuntimeComponent)endpointReference.getComponent();
+        this.reference = (RuntimeComponentReference)endpointReference.getReference();
+        this.binding = (SCABinding)endpointReference.getBinding();
+
+        UtilityExtensionPoint utilities = extensionPoints.getExtensionPoint(UtilityExtensionPoint.class);
+        this.mediator = utilities.getUtility(Mediator.class);
+        this.interfaceContractMapper = utilities.getUtility(InterfaceContractMapper.class);
+        this.scaBindingMapper = utilities.getUtility(SCABindingMapper.class);
+        remotable = isTargetRemote();
+        getDistributedProvider();
+    }
+
+    private boolean isTargetRemote() {
+        return endpointReference.getTargetEndpoint().isRemote();
+    }
+
+    private ReferenceBindingProvider getDistributedProvider() {
+
+        if (remotable) {
+            // initialize the remote provider if it hasn't been done already
+            if (distributedProvider == null) {
+                if (reference.getInterfaceContract() != null && !reference.getInterfaceContract().getInterface()
+                    .isRemotable()) {
+                    throw new ServiceRuntimeException("Reference interface not remotable for component: " + component
+                        .getName()
+                        + " and reference: "
+                        + reference.getName());
+                }
+
+                if (scaBindingMapper.isRemotable(endpointReference)) {
+                    distributedProvider =
+                        new DelegatingSCAReferenceBindingProvider(endpointReference, scaBindingMapper);
+                }
+            }
+        }
+
+        return distributedProvider;
+    }
+
+    public InterfaceContract getBindingInterfaceContract() {
+        if (remotable && distributedProvider != null) {
+            return distributedProvider.getBindingInterfaceContract();
+        } else {
+            // Check if there is a target
+            RuntimeEndpoint endpoint = (RuntimeEndpoint)endpointReference.getTargetEndpoint();
+            if (endpoint != null) {
+                return endpoint.getComponentTypeServiceInterfaceContract();
+            } else {
+                return endpointReference.getComponentTypeReferenceInterfaceContract();
+            }
+        }
+    }
+
+    public boolean supportsOneWayInvocation() {
+        if (remotable && distributedProvider != null) {
+            return distributedProvider.supportsOneWayInvocation();
+        } else {
+            return false;
+        }
+    }
+
+    private Invoker getInvoker(RuntimeEndpointReference epr, Operation operation) {
+        Endpoint target = epr.getTargetEndpoint();
+        if (target != null) {
+            RuntimeComponentService service = (RuntimeComponentService)target.getService();
+            if (service != null) { // not a callback wire
+                InvocationChain chain = ((RuntimeEndpoint)target).getInvocationChain(operation);
+
+                boolean passByValue = false;
+                Operation targetOp = chain.getTargetOperation();
+                if (!operation.getInterface().isRemotable()) {
+                    if (interfaceContractMapper.isCompatibleByReference(operation, targetOp, Compatibility.SUBSET)) {
+                        passByValue = false;
+                    }
+                } else {
+                    Reference ref = epr.getReference().getReference();
+                    // The spec says both ref and service needs to allowsPassByReference
+                    boolean allowsPBR = (ref != null && ref.isAllowsPassByReference()) && chain.allowsPassByReference();
+                    
+                    if (allowsPBR && interfaceContractMapper.isCompatibleByReference(operation,
+                                                                                     targetOp,
+                                                                                     Compatibility.SUBSET)) {
+                        passByValue = false;
+                    } else if (interfaceContractMapper.isCompatibleByValue(operation, targetOp, Compatibility.SUBSET)) {
+                        passByValue = true;
+                    }
+                }
+                // it turns out that the chain source and target operations are the same, and are the operation 
+                // from the target, not sure if thats by design or a bug. The SCA binding invoker needs to know 
+                // the source and target class loaders so pass in the real source operation in the constructor 
+                return chain == null ? null : new SCABindingInvoker(chain, operation, mediator, passByValue, epr, registry);
+            }
+        }
+        return null;
+    }
+
+    public Invoker createInvoker(Operation operation) {
+        if (remotable && distributedProvider != null) {
+            return distributedProvider.createInvoker(operation);
+        } else {
+            Invoker invoker = getInvoker(endpointReference, operation);
+            if (invoker == null) {
+                throw new ServiceUnavailableException(
+                                                      "Unable to create SCA binding invoker for local target " + component
+                                                          .getName()
+                                                          + " reference "
+                                                          + reference.getName()
+                                                          + " (bindingURI="
+                                                          + binding.getURI()
+                                                          + " operation="
+                                                          + operation.getName()
+                                                          + ")");
+            }
+            return invoker;
+        }
+    }
+
+    public void start() {
+        if (started) {
+            return;
+        }
+        if (distributedProvider != null) {
+            distributedProvider.start();
+        }
+        started = true;
+    }
+
+    public void stop() {
+        if (!started) {
+            return;
+        }
+
+        try {
+            if (distributedProvider != null) {
+                distributedProvider.stop();
+            }
+        } finally {
+            started = false;
+        }
+    }
+
+    public void configure() {
+        if (distributedProvider instanceof EndpointReferenceProvider) {
+            ((EndpointReferenceProvider)distributedProvider).configure();
+        }
+    }
+    
+    public boolean supportsNativeAsync() {
+        return true;
+    }
+
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java
new file mode 100644
index 0000000000..77a7e308dd
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/RuntimeSCAServiceBindingProvider.java
@@ -0,0 +1,143 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+import java.util.Iterator;
+
+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.invocation.InvocationChain;
+import org.apache.tuscany.sca.invocation.InvokerAsyncResponse;
+import org.apache.tuscany.sca.invocation.Phase;
+import org.apache.tuscany.sca.provider.EndpointAsyncProvider;
+import org.apache.tuscany.sca.provider.OptimisingBindingProvider;
+import org.apache.tuscany.sca.provider.ServiceBindingProvider;
+import org.apache.tuscany.sca.runtime.RuntimeComponentService;
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+
+/**
+ * The sca service binding provider mediates between the twin requirements of
+ * local sca bindings and remote sca bindings. In the local case is does
+ * very little. When the sca binding model is set as being remote this binding will
+ * try and create a remote service endpoint for remote references to connect to
+ *
+ * @version $Rev$ $Date$
+ */
+public class RuntimeSCAServiceBindingProvider implements EndpointAsyncProvider, OptimisingBindingProvider {
+    private RuntimeEndpoint endpoint;
+    private RuntimeComponentService service;
+
+    private ServiceBindingProvider distributedProvider;
+    private SCABindingMapper scaBindingMapper;
+
+    public RuntimeSCAServiceBindingProvider(ExtensionPointRegistry extensionPoints, RuntimeEndpoint endpoint) {
+        this.endpoint = endpoint;
+        this.service = (RuntimeComponentService)endpoint.getService();
+        UtilityExtensionPoint utilities = extensionPoints.getExtensionPoint(UtilityExtensionPoint.class);
+        this.scaBindingMapper = utilities.getUtility(SCABindingMapper.class);
+
+        // if there is potentially a wire to this service that crosses the node boundary
+        // then we need to create a remote endpoint 
+        if (service.getInterfaceContract().getInterface().isRemotable()) {
+
+            if (scaBindingMapper.isRemotable(endpoint)) {
+                distributedProvider = new DelegatingSCAServiceBindingProvider(endpoint, scaBindingMapper);
+            }
+        }
+    }
+
+    /*
+    protected boolean isDistributed(ExtensionPointRegistry extensionPoints, Endpoint endpoint) {
+        // find if the node config is for distributed endpoints
+        // TODO: temp, need a much better way to do this
+        DomainRegistryFactory domainRegistryFactory = ExtensibleDomainRegistryFactory.getInstance(extensionPoints);
+        Collection<EndpointRegistry> eprs = domainRegistryFactory.getEndpointRegistries();
+        if (eprs.size() > 0) {
+            String eprName = eprs.iterator().next().getClass().getName();
+            return !eprName.equals("org.apache.tuscany.sca.core.assembly.impl.EndpointRegistryImpl");
+        }
+        return false;
+    }
+    */
+
+    public InterfaceContract getBindingInterfaceContract() {
+        if (distributedProvider != null) {
+            return distributedProvider.getBindingInterfaceContract();
+        } else {
+            return endpoint.getComponentTypeServiceInterfaceContract();
+        }
+    }
+
+    public boolean supportsOneWayInvocation() {
+        if (distributedProvider != null) {
+            return distributedProvider.supportsOneWayInvocation();
+        }
+        return false;
+    }
+
+    public void start() {
+        if (distributedProvider != null) {
+            distributedProvider.start();
+        }
+    }
+
+    public void stop() {
+        endpoint.getBinding().setURI(null);
+        if (distributedProvider != null) {
+            distributedProvider.stop();
+        }
+    }
+
+    public void configure() {
+        // TODO Auto-generated method stub   
+    }
+    
+    public boolean supportsNativeAsync() {
+        return true;
+    }
+    
+    public InvokerAsyncResponse createAsyncResponseInvoker() {
+        if (distributedProvider != null) {
+            return ((EndpointAsyncProvider)distributedProvider).createAsyncResponseInvoker();
+        } else {
+            return new SCABindingAsyncResponseInvoker(null, null);
+        }
+    }
+
+    /**
+     * Handles the optimisation for the service side chain, which provides a mechanism for direct local
+     * invocation of the service in cases where the component reference is in the same JVM as the 
+     * component service.  Effectively, this means skipping any Remote Binding listener and its associated
+     * binding chain and data binding processors.
+     * 
+     * This means inserting a SCABindingLocalInvocationInterceptor into the chains for the Endpoint,
+     * which is placed immediately before the Policy processors (and after any Databinding processors)
+     */
+	public void optimiseBinding(RuntimeEndpoint ep) {
+		// To optimise, place an SCA binding Local Invocation interceptor at the start of the POLICY phase
+		// of the service chain...
+		for (InvocationChain chain : ep.getInvocationChains()) {
+			chain.addHeadInterceptor( Phase.SERVICE_POLICY, new SCABindingLocalInvocationInterceptor() );
+		} // end for
+			
+	} // end method optimiseBinding
+    
+} // end class RuntimeSCAServiceBinding
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingAsyncResponseInvoker.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingAsyncResponseInvoker.java
new file mode 100644
index 0000000000..fb7b6210d6
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingAsyncResponseInvoker.java
@@ -0,0 +1,56 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ * 

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ * 

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.    

+ */

+

+package org.apache.tuscany.sca.binding.sca.provider;

+

+import org.apache.tuscany.sca.core.ExtensionPointRegistry;

+import org.apache.tuscany.sca.core.invocation.AsyncResponseInvoker;

+import org.apache.tuscany.sca.invocation.InvokerAsyncResponse;

+import org.apache.tuscany.sca.invocation.Message;

+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;

+import org.oasisopen.sca.ServiceRuntimeException;

+

+/**

+ * @version $Rev: 989157 $ $Date: 2010-08-25 16:02:01 +0100 (Wed, 25 Aug 2010) $

+ */

+public class SCABindingAsyncResponseInvoker implements InvokerAsyncResponse {

+

+     public SCABindingAsyncResponseInvoker(ExtensionPointRegistry extensionPoints,

+                                          RuntimeEndpointReference endpointReference) {

+    }

+    

+    // TODO - this only works for the local case!

+    @SuppressWarnings("unchecked")

+	public void invokeAsyncResponse(Message msg) {

+    	AsyncResponseInvoker<RuntimeEndpointReference> asyncInvoker = 

+    		(AsyncResponseInvoker<RuntimeEndpointReference>)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER");

+    	RuntimeEndpointReference epr;

+    	if( asyncInvoker != null ) {

+    		epr = asyncInvoker.getResponseTargetAddress();

+    	} else {

+    		epr = (RuntimeEndpointReference)msg.getFrom();

+    	} // end if

+    	if( epr != null ) {

+    		epr.invokeAsyncResponse(msg); 

+    	} else {

+    		throw new ServiceRuntimeException("SCABindingAsyncResponseInvoker - invokeAsyncResponse has null epr");

+    	} // end if

+        

+    } // end method invokeAsyncResponse

+}
\ No newline at end of file
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingInvoker.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingInvoker.java
new file mode 100644
index 0000000000..de0b1cfe0e
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingInvoker.java
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+import org.apache.tuscany.sca.core.invocation.AsyncResponseInvoker;
+import org.apache.tuscany.sca.core.invocation.InterceptorAsyncImpl;
+import org.apache.tuscany.sca.databinding.Mediator;
+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.invocation.InvokerAsyncRequest;
+import org.apache.tuscany.sca.invocation.InvokerAsyncResponse;
+import org.apache.tuscany.sca.invocation.Message;
+import org.apache.tuscany.sca.invocation.MessageFactory;
+import org.apache.tuscany.sca.invocation.Phase;
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+
+
+/**
+ * @version $Rev$ $Date$
+ */
+public class SCABindingInvoker extends InterceptorAsyncImpl {
+    private InvocationChain chain;
+    private Mediator mediator;
+    private Operation sourceOperation;
+    private Operation targetOperation;
+    private boolean passByValue;
+    private RuntimeEndpointReference epr;
+    private RuntimeEndpoint ep;
+    private ExtensionPointRegistry registry;
+
+    /**
+     * Construct a SCABindingInvoker that delegates to the service invocation chain
+     */
+    public SCABindingInvoker(InvocationChain chain, Operation sourceOperation, Mediator mediator, 
+    		boolean passByValue, RuntimeEndpointReference epr, ExtensionPointRegistry registry) {
+        super();
+        this.chain = chain;
+        this.mediator = mediator;
+        this.sourceOperation = sourceOperation;
+        this.targetOperation = chain.getTargetOperation();
+        this.passByValue = passByValue;
+        this.epr = epr;
+        this.ep = (RuntimeEndpoint)epr.getTargetEndpoint();
+        this.registry = registry;
+    }
+
+    /**
+     * @see org.apache.tuscany.sca.invocation.Interceptor#getNext()
+     */
+    public Invoker getNext() {
+        return chain.getHeadInvoker(Phase.SERVICE_POLICY);
+    }
+
+    /**
+     * @see org.apache.tuscany.sca.invocation.Interceptor#setNext(org.apache.tuscany.sca.invocation.Invoker)
+     */
+    public void setNext(Invoker next) {
+        // NOOP
+    }
+    
+    public Message processRequest(Message msg){
+        if (passByValue) {
+            msg.setBody(mediator.copyInput(msg.getBody(), sourceOperation, targetOperation));
+        } // end if
+         
+        ep.getInvocationChains();
+        if ( !ep.getCallbackEndpointReferences().isEmpty() ) {
+            RuntimeEndpointReference asyncEPR = (RuntimeEndpointReference) ep.getCallbackEndpointReferences().get(0);
+            // Place a link to the callback EPR into the message headers...
+            msg.getHeaders().put("ASYNC_CALLBACK", asyncEPR );
+        } // end if
+        
+        if( ep.isAsyncInvocation() ) {
+            // Get the message ID 
+            String msgID = (String)msg.getHeaders().get("MESSAGE_ID");
+            
+            String operationName = msg.getOperation().getName();
+            
+            // Create a response invoker and add it to the message headers
+            AsyncResponseInvoker<RuntimeEndpointReference> respInvoker = 
+            	new AsyncResponseInvoker<RuntimeEndpointReference>(ep, null, epr, msgID, operationName, getMessageFactory());
+            respInvoker.setBindingType("SCA_LOCAL");
+            msg.getHeaders().put("ASYNC_RESPONSE_INVOKER", respInvoker);
+        } // end if
+        
+        return msg;
+    } // end method processRequest
+    
+    /**
+     * Regular (sync) processing of response message
+     */
+    public Message processResponse(Message msg){
+        if (passByValue) {
+            // Note source and target operation swapped so result is in source class loader
+            if (msg.isFault()) {
+                msg.setFaultBody(mediator.copyFault(msg.getBody(), sourceOperation, targetOperation));
+            } else {
+                if (sourceOperation.getOutputType() != null) {
+                    msg.setBody(mediator.copyOutput(msg.getBody(), sourceOperation, targetOperation));
+                } // end if
+            } // end if
+        } // end if
+        
+        return msg;
+    } // end method processResponse
+    
+    public void invokeAsyncRequest(Message msg) throws Throwable {
+    	try{ 
+	        msg = processRequest(msg);
+	        InvokerAsyncRequest theNext = (InvokerAsyncRequest)getNext();
+	        if( theNext != null ) theNext.invokeAsyncRequest(msg);
+	        postProcessRequest(msg);
+    	} catch (Throwable e) {
+    		postProcessRequest(msg, e);
+    	} // end try
+    } // end method invokeAsyncRequest
+    
+    public void invokeAsyncResponse(Message msg) {
+        msg = processResponse(msg);
+        
+        // Handle async response Relates_To message ID value
+        @SuppressWarnings("unchecked")
+		AsyncResponseInvoker<RuntimeEndpointReference> respInvoker = 
+        	(AsyncResponseInvoker<RuntimeEndpointReference>)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER");
+        // TODO - this deals with the Local case only - not distributed
+        if( respInvoker != null && "SCA_LOCAL".equals(respInvoker.getBindingType()) ) {
+	        RuntimeEndpointReference responseEPR = respInvoker.getResponseTargetAddress();
+	        msg.setFrom(responseEPR);
+        	String msgID = respInvoker.getRelatesToMsgID();
+	        msg.getHeaders().put("RELATES_TO", msgID);
+        } // end if
+        
+        InvokerAsyncResponse thePrevious = (InvokerAsyncResponse)getPrevious();
+        if (thePrevious != null ) thePrevious.invokeAsyncResponse(msg);
+    } // end method invokeAsyncResponse
+    
+    public boolean isLocalSCABIndingInvoker() {
+        return true;
+    }
+    
+	private MessageFactory getMessageFactory() {
+		FactoryExtensionPoint modelFactories = registry.getExtensionPoint(FactoryExtensionPoint.class);
+		return modelFactories.getFactory(MessageFactory.class);
+	} // end method getMessageFactory
+
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingLocalInvocationInterceptor.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingLocalInvocationInterceptor.java
new file mode 100644
index 0000000000..45933bde63
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingLocalInvocationInterceptor.java
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.sca.provider;
+
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import org.apache.tuscany.sca.core.invocation.AsyncResponseInvoker;
+import org.apache.tuscany.sca.core.invocation.InterceptorAsyncImpl;
+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;
+
+/**
+ * Interceptor used by the SCA Binding on the service side chain to provide a mechanism for optimising
+ * invocations when the reference and the service involved are both in the same JVM, and thus the need
+ * to use a transport of any kind is unnecessary.
+ * 
+ */
+public class SCABindingLocalInvocationInterceptor extends InterceptorAsyncImpl {
+    private static final Logger logger = Logger.getLogger(SCABindingLocalInvocationInterceptor.class.getName());
+      
+    private Invoker next;
+
+	private boolean skipPrevious;    
+    
+    public SCABindingLocalInvocationInterceptor() {
+        super();
+    } // end constructor
+    
+    public Message invoke(Message msg) {
+        return next.invoke(msg);
+    } // end method invoke   
+    
+    public Invoker getNext() {
+        return next;
+    } // end method getNext
+
+    public void setNext(Invoker next) {
+        this.next = next;
+    } // end method setNext
+
+    /**
+     * Process request method is simply a passthrough
+     */
+	public Message processRequest(Message msg) {
+		return msg ;
+	} // end method processRequest
+
+	
+	/**
+	 * Handle an async response
+	 * - deals with the local SCA binding case only (at present)
+	 * - in this case, extract the async response invoker from the message header and call the EPR
+	 *   that is present in the invoker, which is in fact the local EPR from which the original forward
+	 *   request came
+	 */
+    public void invokeAsyncResponse(Message msg) {
+        @SuppressWarnings("unchecked")
+		AsyncResponseInvoker<?> respInvoker = 
+        	(AsyncResponseInvoker<?>)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER");
+        if( respInvoker != null && "SCA_LOCAL".equals(respInvoker.getBindingType()) ) {
+        	// Handle the locally optimised case
+	        RuntimeEndpointReference responseEPR = (RuntimeEndpointReference)respInvoker.getResponseTargetAddress();
+	        msg.setFrom(responseEPR);
+	        // Handle async response Relates_To message ID value
+        	String msgID = respInvoker.getRelatesToMsgID();
+	        msg.getHeaders().put("RELATES_TO", msgID);
+	        
+	        // Call the processing on the reference chain directly
+	        responseEPR.invokeAsyncResponse(msg);
+	        
+	        // Prevent the response being processed by the rest of the service chain
+	        return;
+        } else {
+        	// Carry on processing the response by the rest of the service chain
+            InvokerAsyncResponse thePrevious = (InvokerAsyncResponse)getPrevious();
+            if (thePrevious != null ) thePrevious.invokeAsyncResponse(msg);
+            return;
+        } // end if
+
+    } // end method invokeAsyncResponse
+
+	/**
+	 * processResponse is not called during async response handling (all handled by invokeAsyncResponse)
+	 * - this version is a dummy which does nothing.
+	 */
+	public Message processResponse(Message msg) {
+		return msg;
+	} // end method processResponse
+   
+} // end class 
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingMapper.java b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingMapper.java
new file mode 100644
index 0000000000..f0e6a77b16
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/binding-sca-runtime/src/main/java/org/apache/tuscany/sca/binding/sca/provider/SCABindingMapper.java
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+
+package org.apache.tuscany.sca.binding.sca.provider;
+
+import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
+import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
+
+/**
+ * SCABindingMapper allows us to map binding.sca to any of the bindings available to the runtime 
+ */
+public interface SCABindingMapper {
+
+    /**
+     * Map an endpoint with binding.sca to an endpoint
+     * @param endpoint The endpoint for binding.sca
+     * @return The endpoint for the mapped binding
+     */
+    public RuntimeEndpoint map(RuntimeEndpoint endpoint);
+
+    /**
+     * Map an endpoint reference with binding.sca to an endpoint reference with the mapped binding
+     * @param endpointReference
+     * @return The endpoint reference for the mapped binding
+     */
+    public RuntimeEndpointReference map(RuntimeEndpointReference endpointReference);
+    
+    /**
+     * Check if the remote SCA binding is supported
+     * @return 
+     */
+    boolean isRemotable(RuntimeEndpoint endpoint);
+    boolean isRemotable(RuntimeEndpointReference endpointReference);
+
+}