in modules/assembly-xml/src/main/java/org/apache/tuscany/sca/assembly/xml/CompositeProcessor.java [173:651]
public Composite read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException {
Composite composite = null;
Composite include = null;
Component component = null;
Property property = null;
ComponentService componentService = null;
ComponentReference componentReference = null;
ComponentProperty componentProperty = null;
CompositeService compositeService = null;
CompositeReference compositeReference = null;
Contract contract = null;
Wire wire = null;
Callback callback = null;
QName name = null;
Monitor monitor = context.getMonitor();
Contribution contribution = context.getContribution();
try {
// Read the composite document
while (reader.hasNext()) {
int event = reader.getEventType();
switch (event) {
case START_ELEMENT:
name = reader.getName();
if (COMPOSITE_QNAME.equals(name)) {
// Read a <composite>
composite = assemblyFactory.createComposite();
composite.setSpecVersion(Constants.SCA11_NS);
if (contribution != null) {
composite.setContributionURI(contribution.getURI());
}
composite.setName(new QName(getURIString(reader, TARGET_NAMESPACE), getString(reader, NAME)));
if (!isSet(reader, TARGET_NAMESPACE)) {
// spec says that a composite must have a namespace
warning(monitor, "NoCompositeNamespace", composite, composite.getName().toString());
}
if (isSet(reader, AUTOWIRE)) {
composite.setAutowire(getBoolean(reader, AUTOWIRE));
}
//handle extension attributes
this.readExtendedAttributes(reader, name, composite, extensionAttributeProcessor, context);
composite.setLocal(getBoolean(reader, LOCAL));
policyProcessor.readPolicies(composite, reader);
} else if (INCLUDE_QNAME.equals(name)) {
// Read an <include>
include = assemblyFactory.createComposite();
include.setName(getQName(reader, NAME));
include.setURI(getURIString(reader, URI));
include.setUnresolved(true);
composite.getIncludes().add(include);
} else if (SERVICE_QNAME.equals(name)) {
if (component != null) {
// Read a <component><service>
componentService = assemblyFactory.createComponentService();
contract = componentService;
componentService.setName(getString(reader, NAME));
//handle extension attributes
this.readExtendedAttributes(reader, name, componentService, extensionAttributeProcessor, context);
component.getServices().add(componentService);
policyProcessor.readPolicies(contract, reader);
} else {
// Read a <composite><service>
compositeService = assemblyFactory.createCompositeService();
contract = compositeService;
compositeService.setName(getString(reader, NAME));
String promoted = getURIString(reader, PROMOTE);
if (promoted != null) {
String promotedComponentName;
String promotedServiceName;
int s = promoted.indexOf('/');
if (s == -1) {
promotedComponentName = promoted;
promotedServiceName = null;
} else {
promotedComponentName = promoted.substring(0, s);
promotedServiceName = promoted.substring(s + 1);
}
Component promotedComponent = assemblyFactory.createComponent();
promotedComponent.setUnresolved(true);
promotedComponent.setName(promotedComponentName);
compositeService.setPromotedComponent(promotedComponent);
ComponentService promotedService = assemblyFactory.createComponentService();
promotedService.setUnresolved(true);
promotedService.setName(promotedServiceName);
compositeService.setPromotedService(promotedService);
}
//handle extension attributes
this.readExtendedAttributes(reader, name, compositeService, extensionAttributeProcessor, context);
composite.getServices().add(compositeService);
policyProcessor.readPolicies(contract, reader);
}
// set the parent model so that binding processing can
// detect it they're being read as part of a reference
// or a service
context.setParentModel(contract);
} else if (REFERENCE_QNAME.equals(name)) {
if (component != null) {
// Read a <component><reference>
componentReference = assemblyFactory.createComponentReference();
contract = componentReference;
componentReference.setName(getString(reader, NAME));
readMultiplicity(componentReference, reader);
if (isSet(reader, AUTOWIRE)) {
componentReference.setAutowire(getBoolean(reader, AUTOWIRE));
}
// Read @nonOverridable
String nonOverridable = reader.getAttributeValue(null, NONOVERRIDABLE);
if (nonOverridable != null) {
componentReference.setNonOverridable(Boolean.parseBoolean(nonOverridable));
}
readTargets(componentReference, reader);
componentReference.setWiredByImpl(getBoolean(reader, WIRED_BY_IMPL));
//handle extension attributes
this.readExtendedAttributes(reader,
name,
componentReference,
extensionAttributeProcessor, context);
component.getReferences().add(componentReference);
policyProcessor.readPolicies(contract, reader);
} else {
// Read a <composite><reference>
compositeReference = assemblyFactory.createCompositeReference();
contract = compositeReference;
compositeReference.setName(getString(reader, NAME));
readMultiplicity(compositeReference, reader);
readTargets(compositeReference, reader);
String promote = getString(reader, Constants.PROMOTE);
if (promote != null) {
for (StringTokenizer tokens = new StringTokenizer(promote); tokens.hasMoreTokens();) {
String refName = tokens.nextToken();
Component promotedComponent = assemblyFactory.createComponent();
int index = refName.indexOf('/');
if (index == -1) {
error(monitor, "Invalid reference name", compositeReference, refName);
}
String promotedComponentName = refName.substring(0, index);
promotedComponent.setName(promotedComponentName);
promotedComponent.setUnresolved(true);
compositeReference.getPromotedComponents().add(promotedComponent);
ComponentReference promotedReference =
assemblyFactory.createComponentReference();
promotedReference.setUnresolved(true);
promotedReference.setName(refName);
compositeReference.getPromotedReferences().add(promotedReference);
}
}
compositeReference.setWiredByImpl(getBoolean(reader, WIRED_BY_IMPL));
//handle extension attributes
this.readExtendedAttributes(reader,
name,
compositeReference,
extensionAttributeProcessor, context);
composite.getReferences().add(compositeReference);
policyProcessor.readPolicies(contract, reader);
}
// set the parent model so that binding processing can
// detect it they're being read as part of a reference
// or a service
context.setParentModel(contract);
} else if (PROPERTY_QNAME.equals(name)) {
if (component != null) {
// Read a <component><property>
componentProperty = assemblyFactory.createComponentProperty();
property = componentProperty;
String source = getURIString(reader, SOURCE);
if (source != null) {
source = source.trim();
}
componentProperty.setSource(source);
if (source != null) {
String xPath = prepareSourceXPathString( source );
try {
componentProperty.setSourceXPathExpression(xpathHelper.compile(reader
.getNamespaceContext(), xPath));
} catch (XPathExpressionException e) {
ContributionReadException ce = new ContributionReadException(e);
error(monitor, "ContributionReadException", source, ce);
//throw ce;
}
}
componentProperty.setFile(getURIString(reader, FILE));
//handle extension attributes
this.readExtendedAttributes(reader,
name,
componentProperty,
extensionAttributeProcessor, context);
policyProcessor.readPolicies(property, reader);
readAbstractProperty(componentProperty, reader, context);
// Read the property value
Document value =
readPropertyValue(property.getXSDElement(), property.getXSDType(), property
.isMany(), reader, context);
property.setValue(value);
component.getProperties().add(componentProperty);
} else {
// Read a <composite><property>
property = assemblyFactory.createProperty();
policyProcessor.readPolicies(property, reader);
readAbstractProperty(property, reader, context);
// Read the property value
Document value =
readPropertyValue(property.getXSDElement(), property.getXSDType(), property
.isMany(), reader, context);
property.setValue(value);
composite.getProperties().add(property);
}
// TUSCANY-1949
// If the property doesn't have a value, the END_ELEMENT event is read by the readPropertyValue
if (reader.getEventType() == END_ELEMENT && PROPERTY_QNAME.equals(reader.getName())) {
property = null;
componentProperty = null;
}
} else if (COMPONENT_QNAME.equals(name)) {
// Read a <component>
component = assemblyFactory.createComponent();
component.setName(getString(reader, NAME));
if (isSet(reader, AUTOWIRE)) {
component.setAutowire(getBoolean(reader, AUTOWIRE));
}
if (isSet(reader, URI)) {
component.setURI(getURIString(reader, URI));
}
//handle extension attributes
this.readExtendedAttributes(reader, name, component, extensionAttributeProcessor, context);
composite.getComponents().add(component);
policyProcessor.readPolicies(component, reader);
} else if (WIRE_QNAME.equals(name)) {
// Read a <wire>
wire = assemblyFactory.createWire();
ComponentReference source = assemblyFactory.createComponentReference();
source.setUnresolved(true);
source.setName(getURIString(reader, SOURCE));
wire.setSource(source);
ComponentService target = assemblyFactory.createComponentService();
target.setUnresolved(true);
target.setName(getURIString(reader, TARGET));
wire.setTarget(target);
// Read @replace
String replace = reader.getAttributeValue(null, REPLACE);
if (replace != null) {
wire.setReplace(Boolean.parseBoolean(replace));
}
//handle extension attributes
this.readExtendedAttributes(reader, name, wire, extensionAttributeProcessor, context);
composite.getWires().add(wire);
policyProcessor.readPolicies(wire, reader);
} else if (CALLBACK_QNAME.equals(name)) {
// Read a <callback>
callback = assemblyFactory.createCallback();
contract.setCallback(callback);
callback.setParentContract(contract);
//handle extension attributes
this.readExtendedAttributes(reader, name, callback, extensionAttributeProcessor, context);
policyProcessor.readPolicies(callback, reader);
// set the parent model so that binding processing can
// detect it they're being read as part of a callback
context.setParentModel(callback);
} else if (IMPLEMENTATION_COMPOSITE_QNAME.equals(name)) {
// Read an implementation.composite
Composite implementation = assemblyFactory.createComposite();
implementation.setName(getQName(reader, NAME));
implementation.setUnresolved(true);
//handle extension attributes
this.readExtendedAttributes(reader, name, implementation, extensionAttributeProcessor, context);
component.setImplementation(implementation);
policyProcessor.readPolicies(implementation, reader);
} else if (REQUIRES_QNAME.equals(name)) {
List<QName> intents = getQNames(reader, INTENTS);
for (QName i : intents) {
Intent intent = policyFactory.createIntent();
intent.setName(i);
if (composite != null) {
composite.getRequiredIntents().add(intent);
} else if (component != null) {
component.getRequiredIntents().add(intent);
} else if (contract != null) {
contract.getRequiredIntents().add(intent);
} else if (callback != null) {
callback.getRequiredIntents().add(intent);
}
}
} else if (POLICY_SET_ATTACHMENT_QNAME.equals(name)) {
QName ps = getQName(reader, NAME);
if (ps != null) {
PolicySet policySet = policyFactory.createPolicySet();
policySet.setName(ps);
if (composite != null) {
composite.getPolicySets().add(policySet);
} else if (component != null) {
component.getPolicySets().add(policySet);
} else if (contract != null) {
contract.getPolicySets().add(policySet);
} else if (callback != null) {
callback.getPolicySets().add(policySet);
}
}
} else if(EXTENSION_QNAME.equals(name)) {
// Handle <extension>
//ignore element as this is a wrapper for extensibility
break;
} else {
// Read an extension element
Object extension = extensionProcessor.read(reader, context);
if (extension != null) {
if (extension instanceof InterfaceContract) {
// <service><interface> and
// <reference><interface>
if (contract != null) {
contract.setInterfaceContract((InterfaceContract)extension);
} else {
if (name.getNamespaceURI().equals(SCA11_NS)) {
error(monitor, "UnexpectedInterfaceElement", extension);
//throw new ContributionReadException("Unexpected <interface> element found. It should appear inside a <service> or <reference> element");
} else {
composite.getExtensions().add(extension);
}
}
} else if (extension instanceof Binding) {
if (extension instanceof PolicySubject) {
ExtensionType bindingType = intentAttachPointTypeFactory.createBindingType();
bindingType.setType(name);
bindingType.setUnresolved(true);
((PolicySubject)extension).setExtensionType(bindingType);
}
// <service><binding> and
// <reference><binding>
if (callback != null) {
callback.getBindings().add((Binding)extension);
} else {
if (contract != null) {
contract.getBindings().add((Binding)extension);
} else {
if (name.getNamespaceURI().equals(SCA11_NS)) {
error(monitor, "UnexpectedBindingElement", extension);
//throw new ContributionReadException("Unexpected <binding> element found. It should appear inside a <service> or <reference> element");
} else {
composite.getExtensions().add(extension);
}
}
}
} else if (extension instanceof Implementation) {
if (extension instanceof PolicySubject) {
ExtensionType implType =
intentAttachPointTypeFactory.createImplementationType();
implType.setType(name);
implType.setUnresolved(true);
((PolicySubject)extension).setExtensionType(implType);
}
// <component><implementation>
if (component != null) {
component.setImplementation((Implementation)extension);
} else {
if (name.getNamespaceURI().equals(SCA11_NS)) {
error(monitor, "UnexpectedImplementationElement", extension);
//throw new ContributionReadException("Unexpected <implementation> element found. It should appear inside a <component> element");
} else {
composite.getExtensions().add(extension);
}
}
} else {
// Add the extension element to the current
// element
if (callback != null) {
callback.getExtensions().add(extension);
} else if (contract != null) {
contract.getExtensions().add(extension);
} else if (property != null) {
property.getExtensions().add(extension);
} else if (component != null) {
component.getExtensions().add(extension);
} else {
composite.getExtensions().add(extension);
}
}
}
}
break;
case XMLStreamConstants.CHARACTERS:
break;
case END_ELEMENT:
name = reader.getName();
// Clear current state when reading reaching end element
if (SERVICE_QNAME.equals(name)) {
componentService = null;
compositeService = null;
contract = null;
} else if (INCLUDE_QNAME.equals(name)) {
include = null;
} else if (REFERENCE_QNAME.equals(name)) {
componentReference = null;
compositeReference = null;
contract = null;
} else if (PROPERTY_QNAME.equals(name)) {
componentProperty = null;
property = null;
} else if (COMPONENT_QNAME.equals(name)) {
component = null;
} else if (WIRE_QNAME.equals(name)) {
wire = null;
} else if (CALLBACK_QNAME.equals(name)) {
callback = null;
}
break;
}
// Read the next element
if (reader.hasNext()) {
reader.next();
}
}
} catch (XMLStreamException e) {
ContributionReadException ex = new ContributionReadException(e);
error(monitor, "XMLStreamException", reader, ex);
}
return composite;
}