lib/logstash/codecs/edn_lines.rb in logstash-codec-edn_lines-2.0.4 vs lib/logstash/codecs/edn_lines.rb in logstash-codec-edn_lines-3.0.0

- old
+ new

@@ -18,10 +18,10 @@ public def decode(data) @lines.decode(data) do |event| begin - yield LogStash::Event.new(EDN.read(event["message"])) + yield LogStash::Event.new(EDN.read(event.get("message"))) rescue => e @logger.warn("EDN parse failure. Falling back to plain-text", :error => e, :data => data) yield LogStash::Event.new("message" => data) end end