in library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/InsertField.java [47:67]
public void process(Exchange ex) throws InvalidPayloadException {
JsonNode body = ex.getMessage().getBody(JsonNode.class);
if (body == null) {
throw new InvalidPayloadException(ex, JsonNode.class);
}
switch (body.getNodeType()) {
case ARRAY:
((ArrayNode) body).add(value);
break;
case OBJECT:
((ObjectNode) body).put(field, value);
break;
default:
((ObjectNode) body).put(field, value);
break;
}
ex.getMessage().setBody(body);
}