static final String NODE_REMOVED = REPOSITORY + "NODE_REMOVED";
static final String PROPERTY_CHANGED = REPOSITORY + "PROPERTY_CHANGED";
public void process(final Exchange exchange) throws Exception {
final Message in = exchange.getIn();
final String eventURIBase = in.getHeader(AuditHeaders.EVENT_BASE_URI, String.class);
<BUG>final String eventID = in.getHeader(JmsHeaders.EVENT_ID, String.class);
</BUG>
final Resource eventURI = createResource(eventURIBase + "/" + eventID);
final StringBuilder query = new StringBuilder("update=");
<BUG>query.append(ProcessorUtils.insertData(serializedGraphForMessage(in, eventURI), null));
</BUG>
in.setBody(query.toString());

static final String NODE_REMOVED = REPOSITORY + "NODE_REMOVED";
static final String PROPERTY_CHANGED = REPOSITORY + "PROPERTY_CHANGED";
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);
final StringBuilder query = new StringBuilder("update=");
query.append(ProcessorUtils.insertData(serializedGraphForMessage(in, eventURI), ""));
in.setBody(query.toString());
