diff --git a/logstash-core/src/main/java/org/logstash/ext/JrubyEventExtLibrary.java b/logstash-core/src/main/java/org/logstash/ext/JrubyEventExtLibrary.java index 369ea3fd0..dcd1b6b0e 100644 --- a/logstash-core/src/main/java/org/logstash/ext/JrubyEventExtLibrary.java +++ b/logstash-core/src/main/java/org/logstash/ext/JrubyEventExtLibrary.java @@ -71,6 +71,8 @@ public final class JrubyEventExtLibrary { this.event = new Event( ConvertedMap.newFromRubyHash(context, (RubyHash) data) ); + } else if (data != null && data.getJavaClass().equals(Event.class)) { + this.event = data.toJava(Event.class); } else { initializeFallback(context, data); }