modules/builder/src/main/java/org/apache/tuscany/sca/builder/impl/EndpointReferenceBuilderImpl.java [470:598]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Reference reference = componentReference.getReference(); if (reference instanceof CompositeReference) { // Continue to follow the reference promotion chain collectPromotedComponentReferences((CompositeReference)reference, componentReferences); } else if (reference != null) { // Found a non-composite reference componentReferences.add(componentReference); } } } } /** * Copy a higher level EndpointReference down to a lower level reference which it promotes * @param epRef - the endpoint reference * @param promotedReference - the promoted reference * @return - a copy of the EndpointReference with data merged from the promoted reference */ private EndpointReference copyHigherReference(EndpointReference epRef, ComponentReference promotedReference) { EndpointReference epRefClone = null; try { epRefClone = (EndpointReference)epRef.clone(); } catch (Exception e) { throw new ServiceRuntimeException(e); } // end try // Copy across details of the inner reference //ComponentReference ref = epRefClone.getReference(); //FIXME epRefClone.setReference(promotedReference); return epRefClone; } /** * For all references in a component check that multiplicity is correct * * @param composite * @param component * @param monitor */ private void validateReferenceMultiplicity(Composite composite, Component component, Monitor monitor) { for (ComponentReference componentReference : component.getReferences()) { if (!validateMultiplicity(componentReference.getMultiplicity(), componentReference.getEndpointReferences())) { if (componentReference.getEndpointReferences().isEmpty()) { // No error if the reference is promoted out of the current composite boolean promoted = false; for (Reference reference : composite.getReferences()) { CompositeReference compositeReference = (CompositeReference)reference; if (compositeReference.getPromotedReferences().contains(componentReference)) { promoted = true; break; } } if (!promoted && !componentReference.isForCallback() && !componentReference.isWiredByImpl()) { Monitor.error(monitor, this, Messages.ASSEMBLY_VALIDATION, "ReferenceWithoutTargets", composite.getName().toString(), componentReference.getName()); } } else { // no error if reference is autowire and more targets // than multiplicity have been found if (Boolean.TRUE.equals(componentReference.getAutowire())) { break; } Monitor.error(monitor, this, Messages.ASSEMBLY_VALIDATION, "TooManyReferenceTargets", componentReference.getName()); } } } } /** * For a single component reference check that multiplicity is correct * * @param multiplicity * @param endpointReferences * @return */ private boolean validateMultiplicity(Multiplicity multiplicity, List endpointReferences) { // In some tests multiplicity is not set if (multiplicity == null) { return true; } // Count targets int count = endpointReferences.size(); switch (multiplicity) { case ZERO_N: break; case ZERO_ONE: if (count > 1) { return false; } break; case ONE_ONE: if (count != 1) { return false; } break; case ONE_N: if (count < 1) { return false; } break; } return true; } /** * Evaluates whether the bindings attached to a reference identify one or more target services. * @param reference - the reference * @return true if the bindings identify a target, false otherwise */ private boolean bindingsIdentifyTargets(ComponentReference reference) { for (Binding binding : reference.getBindings()) { - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - modules/builder/src/main/java/org/apache/tuscany/sca/builder/impl/WireBuilderImpl.java [677:791]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Reference reference = componentReference.getReference(); if (reference instanceof CompositeReference) { // Continue to follow the reference promotion chain collectPromotedComponentReferences((CompositeReference)reference, componentReferences); } else if (reference != null) { // Found a non-composite reference componentReferences.add(componentReference); } } } /** * Copy a higher level EndpointReference down to a lower level reference which it promotes * @param epRef - the endpoint reference * @param promotedReference - the promoted reference * @return - a copy of the EndpointReference with data merged from the promoted reference */ private EndpointReference copyHigherReference(EndpointReference epRef, ComponentReference promotedReference) { EndpointReference epRefClone = null; try { epRefClone = (EndpointReference)epRef.clone(); } catch (Exception e) { throw new ServiceRuntimeException(e); // Ignore (we know that EndpointReference2 can be cloned) } // end try // Copy across details of the inner reference // ComponentReference ref = epRefClone.getReference(); //FIXME epRefClone.setReference(promotedReference); return epRefClone; } private void validateReferenceMultiplicity(Composite composite, Component component, Monitor monitor) { for (ComponentReference componentReference : component.getReferences()) { if (!validateMultiplicity(componentReference.getMultiplicity(), componentReference.getEndpointReferences())) { if (componentReference.getEndpointReferences().isEmpty()) { // No error if the reference is promoted out of the current composite boolean promoted = false; for (Reference reference : composite.getReferences()) { CompositeReference compositeReference = (CompositeReference)reference; if (compositeReference.getPromotedReferences().contains(componentReference)) { promoted = true; break; } } if (!promoted && !componentReference.isForCallback() && !componentReference.isWiredByImpl()) { Monitor.error(monitor, this, Messages.ASSEMBLY_VALIDATION, "ReferenceWithoutTargets", composite.getName().toString(), componentReference.getName()); } } else { // no error if reference is autowire and more targets // than multiplicity have been found if (Boolean.TRUE.equals(componentReference.getAutowire())) { break; } Monitor.error(monitor, this, Messages.ASSEMBLY_VALIDATION, "TooManyReferenceTargets", componentReference.getName()); } } } } private boolean validateMultiplicity(Multiplicity multiplicity, List endpointReferences) { // In some tests multiplicity is not set if (multiplicity == null) { return true; } // Count targets int count = endpointReferences.size(); switch (multiplicity) { case ZERO_N: break; case ZERO_ONE: if (count > 1) { return false; } break; case ONE_ONE: if (count != 1) { return false; } break; case ONE_N: if (count < 1) { return false; } break; } return true; } /** * Evaluates whether the bindings attached to a reference identify one or more target services. * @param reference - the reference * @return true if the bindings identify a target, false otherwise */ private boolean bindingsIdentifyTargets(ComponentReference reference) { for (Binding binding : reference.getBindings()) { - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -