in common/servicemix-components/src/main/java/org/apache/servicemix/components/validation/ValidateComponent.java [131:222]
protected boolean transform(MessageExchange exchange, NormalizedMessage in, NormalizedMessage out) throws MessagingException {
Validator validator = schema.newValidator();
// create a new errorHandler and set it on the validator
MessageAwareErrorHandler errorHandler = errorHandlerFactory.createMessageAwareErrorHandler();
validator.setErrorHandler(errorHandler);
DOMResult result = new DOMResult();
// Transform first so that the input source will be parsed only once
// if it is a StreamSource
getMessageTransformer().transform(exchange, in, out);
try {
SourceTransformer sourceTransformer = new SourceTransformer();
// Only DOMSource and SAXSource are allowed for validating
// See http://java.sun.com/j2se/1.5.0/docs/api/javax/xml/validation/Validator.html#validate(javax.xml.transform.Source,%20javax.xml.transform.Result)
// As we expect a DOMResult as output, we must ensure that the input is a
// DOMSource
DOMSource src = sourceTransformer.toDOMSource(out.getContent());
doValidation(validator,src,result);
if (errorHandler.hasErrors()) {
Fault fault = exchange.createFault();
// Dont set the schema and source document as properties on the fault
// because they are not serializable
//fault.setProperty("org.apache.servicemix.xml", src);
// Dont set the schema because it contains an instance of
// com.sun.org.apache.xerces.internal.jaxp.validation.xs.SchemaImpl that
// is not serializable
//fault.setProperty("org.apache.servicemix.schema", schema);
/*
* check if this error handler supports the capturing of
* error messages.
*/
if (errorHandler.capturesMessages()) {
/*
* In descending order of preference select a format to use. If
* neither DOMSource, StringSource or String are supported throw
* a messaging exception.
*/
if (errorHandler.supportsMessageFormat(DOMSource.class)) {
fault.setContent(
(DOMSource)errorHandler.getMessagesAs(DOMSource.class));
} else if (errorHandler.supportsMessageFormat(StringSource.class)) {
fault.setContent(sourceTransformer.toDOMSource(
(StringSource)errorHandler.getMessagesAs(StringSource.class)));
} else if (errorHandler.supportsMessageFormat(String.class)) {
fault.setContent(
sourceTransformer.toDOMSource(
new StringSource(
(String)errorHandler.getMessagesAs(String.class))));
} else {
throw new MessagingException("MessageAwareErrorHandler implementation " +
errorHandler.getClass().getName() +
" does not support a compatible error message format.");
}
} else {
/*
* we can't do much here if the ErrorHandler implementation does
* not support capturing messages
*/
fault.setContent(new DOMSource(result.getNode(), result.getSystemId()));
}
if (!handlingErrorMethod.equalsIgnoreCase(FAULT_FLOW)) {
// HANDLE AS JBI FAULT
throw new FaultException("Failed to validate against schema: " + schema, exchange, fault);
} else {
MessageUtil.transfer(fault, out);
return true;
}
}
else {
// Retrieve the ouput of the validation
// as it may have been changed by the validator
out.setContent(new DOMSource(result.getNode(), result.getSystemId()));
return true;
}
}
catch (SAXException e) {
throw new MessagingException(e);
}
catch (IOException e) {
throw new MessagingException(e);
}
catch (ParserConfigurationException e) {
throw new MessagingException(e);
}
catch (TransformerException e) {
throw new MessagingException(e);
}
}