code: public void configure() throws Exception {
  
          /**
           * A generic error handler (specific to this RouteBuilder)
           */
          onException(Exception.class)
              .maximumRedeliveries("{{error.maxRedeliveries}}")
              .log("Event Routing Error: ${routeId}");
  
          /**
           * Process a message.
           */
          from("{{input.stream}}")
              .routeId("AuditFcrepoRouter")
              .process(new EventProcessor())
              .filter(not(in(tokenizePropertyPlaceholder(getContext(), "{{filter.containers}}", ",").stream()
                          .map(uri -> or(
                              header(FCREPO_URI).startsWith(constant(uri + "/")),
                              header(FCREPO_URI).isEqualTo(constant(uri))))
                          .collect(toList()))))
                  .to("direct:event");
  
          from("direct:event")
              .routeId("AuditEventRouter")
              .setHeader(AuditHeaders.EVENT_BASE_URI, simple("{{event.baseUri}}"))
              .process(new AuditSparqlProcessor())
              .log(LoggingLevel.INFO, "org.fcrepo.camel.audit",
                      "Audit Event: ${headers.CamelFcrepoUri} :: ${headers[CamelAuditEventUri]}")
              .to("{{triplestore.baseUrl}}?useSystemProperties=true");
      }
docs: Configure the message route workflow.