public void configure() throws Exception {

        final Namespaces ns = new Namespaces("rdf", RDF.uri);
        ns.add("premis", "http://www.loc.gov/premis/rdf/v1#");

        /**
         * A generic error handler (specific to this RouteBuilder)
         */
        onException(Exception.class)
            .maximumRedeliveries("{{error.maxRedeliveries}}")
            .log("Index Routing Error: ${routeId}");

        /**
         * Handle fixity events
         */
        from("{{fixity.stream}}")
            .routeId("FcrepoFixity")
            .to("fcrepo:{{fcrepo.baseUrl}}?preferInclude=ServerManged&accept=application/rdf+xml")
            .filter().xpath(
                    "/rdf:RDF/rdf:Description/rdf:type" +
                    "[@rdf:resource='" + REPOSITORY + "Binary']", ns)
            .log(LoggingLevel.INFO, LOGGER,
                    "Checking Fixity for ${headers[CamelFcrepoUri]}")
            .delay(simple("{{fixity.delay}}"))
            .to("fcrepo:{{fcrepo.baseUrl}}?fixity=true&accept=application/rdf+xml")
            .choice()
                .when().xpath(
                        "/rdf:RDF/rdf:Description/premis:hasEventOutcome" +
                        "[text()='SUCCESS']", ns)
                    .to("{{fixity.success}}")
                .otherwise()
                    .log(LoggingLevel.WARN, LOGGER,
                        "Fixity error on ${headers[CamelFcrepoUri]}")
                    .to("{{fixity.failure}}");
    }
public void configure ( ) throws Exception { final Namespaces ns = new Namespaces ( "rdf" , RDF . uri ) ; ns . add ( "premis" , "http://www.loc.gov/premis/rdf/v1#" ) ; onException ( Exception . class ) . maximumRedeliveries ( "{{error.maxRedeliveries}}" ) . log ( "Index Routing Error: ${routeId}" ) ; from ( "{{fixity.stream}}" ) . routeId ( "FcrepoFixity" ) . to ( "fcrepo:{{fcrepo.baseUrl}}?preferInclude=ServerManged&accept=application/rdf+xml" ) . filter ( ) . xpath ( "/rdf:RDF/rdf:Description/rdf:type" + "[@rdf:resource='" + REPOSITORY + "Binary']" , ns ) . log ( LoggingLevel . INFO , LOGGER , "Checking Fixity for ${headers[CamelFcrepoUri]}" ) . delay ( simple ( "{{fixity.delay}}" ) ) . to ( "fcrepo:{{fcrepo.baseUrl}}?fixity=true&accept=application/rdf+xml" ) . choice ( ) . when ( ) . xpath ( "/rdf:RDF/rdf:Description/premis:hasEventOutcome" + "[text()='SUCCESS']" , ns ) . to ( "{{fixity.success}}" ) . otherwise ( ) . log ( LoggingLevel . WARN , LOGGER , "Fixity error on ${headers[CamelFcrepoUri]}" ) . to ( "{{fixity.failure}}" ) ; }
Configure the message route workflow.