Added ExtractField method to library
diff --git a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/ExtractField.java b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/ExtractField.java
index 90a2f7b..81dae10 100644
--- a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/ExtractField.java
+++ b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/ExtractField.java
@@ -25,7 +25,7 @@
public class ExtractField {
- public Object process(@ExchangeProperty("field") String field, Exchange ex) throws InvalidPayloadException {
+ public void process(@ExchangeProperty("field") String field, Exchange ex) throws InvalidPayloadException {
Map<Object, Object> body = ex.getMessage().getBody(Map.class);
if (body == null) {
String val = ex.getMessage().getMandatoryBody(String.class);
@@ -33,7 +33,7 @@
// TODO: make this configurable
body.put("content", val);
}
- return body.get(field);
+ ex.getMessage().setBody(body.get(field));
}
}
