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