I found the solution. While the code did validate the XML to the schema, I needed to add a conditional statement to transfer to failure: import groovy.xml.XmlSlurper import groovy.xml.XmlUtil import javax.xml.transform.stream.StreamSource import javax.xml.validation.SchemaFactory import javax.xml.XMLConstants import org.xml.sax.ErrorHandler import org.xml.sax.SAXParseException def flowFile = session.get() if (!flowFile) return def fileXML = flowFile.read().getText("UTF-8") def xmlContent = new XmlSlurper().parseText(fileXML.trim().replaceFirst("^([\\W]+)<","<").replaceAll('\'','\'\'')) def schemaFile = flowFile.getAttribute('XMLSchema') def schemaFactory = SchemaFactory.newInstance(XMLConstants.W3C_XML_SCHEMA_NS_URI) def schema = schemaFactory.newSchema(new File(schemaFile)) def validator = schema.newValidator() def validationErrors = new StringBuilder() validator.setErrorHandler(new ErrorHandler() { @Override void warning(org.xml.sax.SAXParseException e) throws org.xml.sax.SAXException { validationErrors.append("<p>Warning: ${e.message}</p>") } @Override void error(org.xml.sax.SAXParseException e) throws org.xml.sax.SAXException { validationErrors.append("<p>Error: ${e.message}</p>") } @Override void fatalError(org.xml.sax.SAXParseException e) throws org.xml.sax.SAXException { validationErrors.append("<p>Fatal Error: ${e.message}</p>") } }) try { validator.validate(new StreamSource(new StringReader(XmlUtil.serialize(xmlContent)))) if (validationErrors.length() > 0) { flowFile = session.putAttribute(flowFile, "xml.validation.errors", validationErrors.toString()) session.transfer(flowFile, REL_FAILURE) } else { session.transfer(flowFile, REL_SUCCESS) } } catch (org.xml.sax.SAXParseException e) { validationErrors.append("Validation failed: ${e.message}\n") flowFile = session.putAttribute(flowFile, "xml.validation.errors", validationErrors.toString()) session.transfer(flowFile, REL_FAILURE) }
... View more
