code: 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}}");
      }
docs: Configure the message route workflow.