diff --git a/src/main/java/com/example/filter/Reverse.java b/src/main/java/com/example/filter/Reverse.java index b096bc3..2c8e371 100644 --- a/src/main/java/com/example/filter/Reverse.java +++ b/src/main/java/com/example/filter/Reverse.java @@ -28,15 +28,17 @@ protected void prepare() { */ @Override protected Map filter(final Map event) { - + boolean success = false; for (String field : this.fields) { if (!event.containsKey(field)) { continue; } + success = true; String oldValue = event.get(field).toString(); String newValue = new StringBuilder(oldValue).reverse().toString(); event.put(field, newValue); } + postProcess(event, success); return event; } }