@Override
    public void endProcessing() {
        try {
            // Return the current schema to the pool if we have one.
            returnCurrentSchema();
        } finally {
            super.endProcessing();
        }
    }
@see stroom.pipeline.filter.AbstractXMLFilter#startProcessing()
stroom-pipeline/src/main/java/stroom/pipeline/filter/SchemaFilter.java