in proxy/cloudhsm/proxy/src/main/java/com/amazon/aws/pix/cloudhsm/proxy/processor/CaptureRequestProcessor.java [15:30]
public void process(Exchange exchange) throws Exception {
Map<String, Object> headers = exchange.getIn().getHeaders();
AuditLog auditLog = new AuditLog();
auditLog.setRequestMethod(headers.get("CamelHttpMethod"));
auditLog.setRequestPath(headers.get("CamelHttpPath"));
auditLog.setRequestQuery(headers.get("CamelHttpQuery"));
auditLog.setRequestBody(exchange.getIn().getBody(String.class));
auditLog.setRequestHeader(
headers.entrySet().stream()
.filter(e -> !e.getKey().startsWith("Camel"))
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue))
);
exchange.setProperty(REQUEST_LOG_PROPERTY, auditLog);
}