in modules/binding-rest/src/main/java/org/apache/tuscany/sca/binding/rest/xml/RESTBindingProcessor.java [107:246]
public RESTBinding read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
RESTBinding restBinding = restBindingFactory.createRESTBinding();
/**
* <tuscany:binding.rest uri="http://localhost:8085/Customer" readTimeout="60000">
* <tuscany:wireFormat.xml />
* <tuscany:operationSelector.jaxrs />
* <tuscany:http-headers>
* <tuscany:header name="Cache-Control" value="no-cache"/>
* <tuscany:header name="Expires" value="-1"/>
* </tuscany:http-headers>
* <tuscany:response>
* <tuscany:wireFormat.json />
* </tuscany:response>
* </tuscany:binding.rest>
*
*/
while(reader.hasNext()) {
QName elementName = null;
int event = reader.getEventType();
switch (event) {
case START_ELEMENT:
elementName = reader.getName();
if(RESTBinding.TYPE.equals(elementName)) {
// binding attributes
String name = getString(reader, NAME);
if(name != null) {
restBinding.setName(name);
}
String uri = getURIString(reader, URI);
if (uri != null) {
restBinding.setURI(uri);
}
String readTimeout = getString(reader, READ_TIMEOUT);
if (readTimeout != null) {
restBinding.setReadTimeout(Integer.valueOf(readTimeout));
}
String corsAttr = reader.getAttributeValue(null, CORS);
if(corsAttr != null) {
restBinding.setCORS(getBoolean(reader, CORS));
} else {
// Default to true
restBinding.setCORS(true);
}
break;
} else if (HEADERS_QNAME.equals(elementName)) {
// ignore wrapper element
break;
} else if (HEADER_QNAME.equals(elementName)) {
// header name/value pair
String name = getString(reader, NAME);
String value = getURIString(reader, VALUE);
if(name != null) {
restBinding.getHttpHeaders().add(new HTTPHeader(name, value));
}
break;
} else if (RESPONSE_QNAME.equals(elementName)) {
// skip response
reader.next();
// and position to the next start_element event
while (reader.hasNext()) {
int sub_event = reader.getEventType();
switch (sub_event) {
case START_ELEMENT:
elementName = reader.getName();
break;
default: reader.next();
}
break;
}
// dispatch to read wire format for the response
//Object extension = extensionProcessor.read(reader, context);
Object extension = readWireFormatAndOperationSelectorExtensions(reader);
if (extension != null) {
if (extension instanceof WireFormat) {
restBinding.setResponseWireFormat((WireFormat)extension);
}
}
break;
} else if(WIRE_FORMAT_JSON.equals(elementName) || WIRE_FORMAT_XML.equals(elementName) ||
OPERATION_SELCTOR_JAXRS.equals(elementName) || OPERATION_SELCTOR_RPC.equals(elementName)) {
// Read wireFormat and/or operationSelector extension elements
Object extension = readWireFormatAndOperationSelectorExtensions(reader);
if (extension != null) {
if (extension instanceof WireFormat) {
restBinding.setRequestWireFormat((WireFormat)extension);
restBinding.setResponseWireFormat((WireFormat)extension);
} else if(extension instanceof OperationSelector) {
restBinding.setOperationSelector((OperationSelector)extension);
restBinding.setCORS(true);
}
}
break;
} else {
// Read an extension element
Object extension = extensionProcessor.read(reader, context);
if (extension != null) {
if (extension instanceof CORSConfiguration) {
restBinding.setCORSConfiguration((CORSConfiguration)extension);
}
}
break;
}
case END_ELEMENT:
elementName = reader.getName();
if(RESTBinding.TYPE.equals(elementName)) {
return restBinding;
}
break;
}
// Read the next element
if (reader.hasNext()) {
reader.next();
}
}
return restBinding;
}