public void process()

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);
    }