diff options
Diffstat (limited to '')
2 files changed, 9 insertions, 18 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 733880a9b3..e0b866ddb9 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 @@ -315,16 +315,12 @@ public class RuntimeEndpointImpl extends EndpointImpl implements RuntimeEndpoint List<PolicyProvider> pps = getPolicyProviders(); if (pps != null) { for (PolicyProvider p : pps) { - // TODO - SL - Need to get the binding policy providers -/* - if (p instanceof BindingPolicyProvider) { - Interceptor interceptor = ((BindingPolicyProvider)p).createBindingInterceptor(); - if (interceptor != null) { - bindingInvocationChain.addInterceptor(interceptor); - } + Interceptor interceptor = p.createBindingInterceptor(); + if (interceptor != null) { + bindingInvocationChain.addInterceptor(interceptor); } -*/ } + } // TODO - add something on the end of the wire to invoke the diff --git a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointReferenceImpl.java b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointReferenceImpl.java index fc5a942186..e2cd2960ba 100644 --- a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointReferenceImpl.java +++ b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/RuntimeEndpointReferenceImpl.java @@ -346,15 +346,10 @@ public class RuntimeEndpointReferenceImpl extends EndpointReferenceImpl implemen // add the policy interceptors to the service binding wire // find out which policies are active for (PolicyProvider p : getPolicyProviders()) { - // TODO - SL - Need to get the binding policy providers -/* - if (p instanceof BindingPolicyProvider) { - Interceptor interceptor = ((BindingPolicyProvider)p).createBindingInterceptor(); - if (interceptor != null) { - bindingInvocationChain.addInterceptor(interceptor); - } + Interceptor interceptor = p.createBindingInterceptor(); + if (interceptor != null) { + bindingInvocationChain.addInterceptor(interceptor); } -*/ } } @@ -392,9 +387,9 @@ public class RuntimeEndpointReferenceImpl extends EndpointReferenceImpl implemen List<PolicyProvider> pps = getPolicyProviders(); if (pps != null) { for (PolicyProvider p : pps) { - Interceptor interceptor = p.createInterceptor(operation); + Interceptor interceptor = p.createBindingInterceptor(); if (interceptor != null) { - chain.addInterceptor(p.createInterceptor(operation)); + chain.addInterceptor(interceptor); } } } |