lib/fluent/plugin/out_logentries.rb in fluent-plugin-logentries-0.2.5 vs lib/fluent/plugin/out_logentries.rb in fluent-plugin-logentries-0.2.6
- old
+ new
@@ -114,10 +114,11 @@
next unless record.has_key? "message"
token = get_token(tag, record)
next if token.nil?
- message = record["message"];
+ # Clean up the string to avoid blank line in logentries
+ message = record["message"].rstrip()
send_logentries("#{token} #{message} \n")
end
end
def send_logentries(data)