code: public void process(final Exchange exchange) throws Exception {
          final Message in = exchange.getIn();
          final String eventURIBase = in.getHeader(AuditHeaders.EVENT_BASE_URI, String.class);
          final String eventID = in.getHeader(FCREPO_EVENT_ID, String.class);
          final Resource eventURI = createResource(eventURIBase + "/" + eventID);
  
          // generate SPARQL Update
          final StringBuilder query = new StringBuilder("update=");
          query.append(ProcessorUtils.insertData(serializedGraphForMessage(in, eventURI), ""));
  
          // update exchange
          in.setBody(query.toString());
          in.setHeader(AuditHeaders.EVENT_URI, eventURI.toString());
          in.setHeader(Exchange.CONTENT_TYPE, "application/x-www-form-urlencoded");
          in.setHeader(Exchange.HTTP_METHOD, "POST");
      }
docs: Define how a message should be processed.
  
  @param exchange the current camel message exchange