lib/fluent/plugin/out_loggly_buffered.rb in fluent-plugin-loggly-0.0.6 vs lib/fluent/plugin/out_loggly_buffered.rb in fluent-plugin-loggly-0.0.7
- old
+ new
@@ -53,10 +53,10 @@
def write(chunk)
records = []
chunk.msgpack_each {|tag,time,record|
record['timestamp'] ||= Time.at(time).iso8601 if @output_include_time
- records.push(record.to_json)
+ records.push(Yajl::Encoder.encode(record))
}
$log.debug "#{records.length} records sent"
post = Net::HTTP::Post.new @uri.path
post.body = records.join("\n")
begin