diff options
3 files changed, 120 insertions, 17 deletions
diff --git a/branches/sca-java-1.3/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/builder/AutomaticBinding.java b/branches/sca-java-1.3/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/builder/AutomaticBinding.java new file mode 100644 index 0000000000..97708f9ef5 --- /dev/null +++ b/branches/sca-java-1.3/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/builder/AutomaticBinding.java @@ -0,0 +1,39 @@ +/* + * 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.assembly.builder; + +/** + * Represent a binding that has been added automatically to the model rather + * than being specified by the user through the composite file + * + * @version $Rev$ $Date$ + * + */ +public interface AutomaticBinding extends Cloneable { + + /** + * @param isAutomatic + */ + void setIsAutomatic(boolean isAutomatic); + + /** + * @return isAutomatic + */ + boolean getIsAutomatic(); +} diff --git a/branches/sca-java-1.3/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/builder/impl/BaseConfigurationBuilderImpl.java b/branches/sca-java-1.3/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/builder/impl/BaseConfigurationBuilderImpl.java index 52cba0c18c..853c11c2ee 100644 --- a/branches/sca-java-1.3/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/builder/impl/BaseConfigurationBuilderImpl.java +++ b/branches/sca-java-1.3/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/builder/impl/BaseConfigurationBuilderImpl.java @@ -46,6 +46,7 @@ import org.apache.tuscany.sca.assembly.Reference; import org.apache.tuscany.sca.assembly.SCABinding; import org.apache.tuscany.sca.assembly.SCABindingFactory; import org.apache.tuscany.sca.assembly.Service; +import org.apache.tuscany.sca.assembly.builder.AutomaticBinding; import org.apache.tuscany.sca.assembly.builder.ComponentPreProcessor; import org.apache.tuscany.sca.assembly.builder.CompositeBuilderException; import org.apache.tuscany.sca.definitions.SCADefinitions; @@ -832,25 +833,35 @@ public abstract class BaseConfigurationBuilderImpl { newComponentService.setService(promotedService.getService()); // set the bindings using the top level bindings to override the // lower level bindings - if (compositeService.getBindings().size() > 0){ + if (bindingsSpecifiedManually(compositeService.getBindings())){ newComponentService.getBindings() .addAll(compositeService.getBindings()); } else { - newComponentService.getBindings() - .addAll(promotedService.getBindings()); + for (Binding binding : promotedService.getBindings()){ + try { + newComponentService.getBindings().add((Binding)binding.clone()); + } catch(CloneNotSupportedException ex){ + // this binding can't be used in the promoted service + } + } } newComponentService.setInterfaceContract(compositeService.getInterfaceContract()); if (compositeService.getInterfaceContract() != null && compositeService .getInterfaceContract().getCallbackInterface() != null) { newComponentService.setCallback(assemblyFactory.createCallback()); if ((compositeService.getCallback() != null) && - (compositeService.getCallback().getBindings().size() > 0)){ + (bindingsSpecifiedManually(compositeService.getCallback().getBindings()))){ newComponentService.getCallback().getBindings() .addAll(compositeService.getCallback().getBindings()); } else if ((promotedService.getCallback() != null) && - (promotedService.getCallback().getBindings().size() > 0)){ - newComponentService.getBindings() - .addAll(promotedService.getBindings()); + (bindingsSpecifiedManually(promotedService.getCallback().getBindings()))){ + for (Binding binding : promotedService.getCallback().getBindings()){ + try { + newComponentService.getCallback().getBindings().add((Binding)binding.clone()); + } catch(CloneNotSupportedException ex){ + // this binding can't be used in the promoted service + } + } } } @@ -909,20 +920,28 @@ public abstract class BaseConfigurationBuilderImpl { newComponentService.setName("$promoted$." + componentService.getName()); promotedComponent.getServices().add(newComponentService); newComponentService.setService(promotedService.getService()); + // set the bindings using the top level bindings to override the // lower level bindings - if (componentService.getBindings().size() > 0){ + if (bindingsSpecifiedManually(componentService.getBindings())){ newComponentService.getBindings() .addAll(componentService.getBindings()); - } else if (compositeService.getBindings().size() > 0){ + } else if (bindingsSpecifiedManually(compositeService.getBindings())){ newComponentService.getBindings() .addAll(compositeService.getBindings()); } else { - newComponentService.getBindings() - .addAll(promotedService.getBindings()); + for (Binding binding : promotedService.getBindings()){ + try { + newComponentService.getBindings().add((Binding)binding.clone()); + } catch(CloneNotSupportedException ex){ + // this binding can't be used in the promoted service + } + } } + newComponentService.setInterfaceContract(componentService .getInterfaceContract()); + if (componentService.getInterfaceContract() != null && componentService.getInterfaceContract().getCallbackInterface() != null) { @@ -931,17 +950,22 @@ public abstract class BaseConfigurationBuilderImpl { // set the bindings using the top level bindings to override the // lower level bindings if ((componentService.getCallback() != null) && - (componentService.getCallback().getBindings().size() > 0)){ + (bindingsSpecifiedManually(componentService.getCallback().getBindings()))){ newComponentService.getCallback().getBindings() .addAll(componentService.getCallback().getBindings()); } else if ((compositeService.getCallback() != null) && - (compositeService.getCallback().getBindings().size() > 0)){ + (bindingsSpecifiedManually(compositeService.getCallback().getBindings()))){ newComponentService.getCallback().getBindings() .addAll(compositeService.getCallback().getBindings()); } else if ((promotedService.getCallback() != null) && - (promotedService.getCallback().getBindings().size() > 0)){ - newComponentService.getBindings() - .addAll(promotedService.getBindings()); + (bindingsSpecifiedManually(promotedService.getCallback().getBindings()))){ + for (Binding binding : promotedService.getCallback().getBindings()){ + try { + newComponentService.getCallback().getBindings().add((Binding)binding.clone()); + } catch(CloneNotSupportedException ex){ + // this binding can't be used in the promoted service + } + } } } @@ -957,6 +981,28 @@ public abstract class BaseConfigurationBuilderImpl { } /** + * If the bindings are specified in the composite file return true as they should + * otherwise return false + * + * @param bindings + * @return true if the bindings were specified manually + */ + private boolean bindingsSpecifiedManually(List<Binding> bindings){ + + if (bindings.size() > 1){ + return true; + } else if ((bindings.size() == 1) && + (bindings.get(0) instanceof AutomaticBinding) && + (((AutomaticBinding)bindings.get(0)).getIsAutomatic() == true )){ + return false; + } else if (bindings.size() == 1) { + return true; + } else { + return false; + } + } + + /** * @param composite */ private void configureSourcedProperties(Composite composite, List<ComponentProperty> propertySettings) { @@ -1028,6 +1074,12 @@ public abstract class BaseConfigurationBuilderImpl { private SCABinding createSCABinding() { SCABinding scaBinding = scaBindingFactory.createSCABinding(); + // mark the bindings that are added automatically so that theu can + // can be disregarded for overriding purposes + if (scaBinding instanceof AutomaticBinding){ + ((AutomaticBinding)scaBinding).setIsAutomatic(true); + } + if ( policyDefinitions != null ) { for ( IntentAttachPointType attachPointType : policyDefinitions.getBindingTypes() ) { if ( attachPointType.getName().equals(BINDING_SCA_QNAME)) { diff --git a/branches/sca-java-1.3/modules/binding-sca/src/main/java/org/apache/tuscany/sca/binding/sca/impl/SCABindingImpl.java b/branches/sca-java-1.3/modules/binding-sca/src/main/java/org/apache/tuscany/sca/binding/sca/impl/SCABindingImpl.java index 3c5509eaa6..c93ddd9503 100644 --- a/branches/sca-java-1.3/modules/binding-sca/src/main/java/org/apache/tuscany/sca/binding/sca/impl/SCABindingImpl.java +++ b/branches/sca-java-1.3/modules/binding-sca/src/main/java/org/apache/tuscany/sca/binding/sca/impl/SCABindingImpl.java @@ -27,6 +27,7 @@ import org.apache.tuscany.sca.assembly.ComponentService; import org.apache.tuscany.sca.assembly.Extensible; import org.apache.tuscany.sca.assembly.OptimizableBinding; import org.apache.tuscany.sca.assembly.SCABinding; +import org.apache.tuscany.sca.assembly.builder.AutomaticBinding; import org.apache.tuscany.sca.policy.Intent; import org.apache.tuscany.sca.policy.IntentAttachPointType; import org.apache.tuscany.sca.policy.PolicySet; @@ -37,7 +38,7 @@ import org.apache.tuscany.sca.policy.PolicySetAttachPoint; * * @version $Rev$ $Date$ */ -public class SCABindingImpl implements SCABinding, Extensible, PolicySetAttachPoint, OptimizableBinding { +public class SCABindingImpl implements SCABinding, Extensible, PolicySetAttachPoint, OptimizableBinding, AutomaticBinding { private String name; private String uri; private List<Object> extensions = new ArrayList<Object>(); @@ -50,6 +51,8 @@ public class SCABindingImpl implements SCABinding, Extensible, PolicySetAttachPo private Binding targetBinding; private List<PolicySet> applicablePolicySets = new ArrayList<PolicySet>(); + private boolean isAutomatic = false; + public List<PolicySet> getApplicablePolicySets() { return applicablePolicySets; } @@ -208,4 +211,13 @@ public class SCABindingImpl implements SCABinding, Extensible, PolicySetAttachPo public void setRequiredIntents(List<Intent> intents) { this.requiredIntents = intents; } + + + public void setIsAutomatic(boolean isAutomatic){ + this.isAutomatic = isAutomatic; + } + + public boolean getIsAutomatic(){ + return this.isAutomatic; + } } |