public void process()

in library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/ExtractField.java [53:73]

• 18 lines of code
• 6 McCabe index (conditional complexity)

    public void process(Exchange ex) throws InvalidPayloadException {
        ObjectMapper mapper = new ObjectMapper();
        JsonNode jsonNodeBody = ex.getMessage().getBody(JsonNode.class);

        if (jsonNodeBody == null) {
            throw new InvalidPayloadException(ex, JsonNode.class);

        }

        Map<Object, Object> body = mapper.convertValue(jsonNodeBody, new TypeReference<Map<Object, Object>>(){});
        if (!headerOutput || (strictHeaderCheck && checkHeaderExistence(ex))) {
            ex.getMessage().setBody(body.get(field));
        } else {
            extractToHeader(ex, body);
        }
        if (trimField) {
            ex.setProperty("trimField", "true");
        } else {
            ex.setProperty("trimField", "false");
        }
    }