lib/fluent/plugin/out_newrelic.rb in fluent-plugin-newrelic-0.2.3 vs lib/fluent/plugin/out_newrelic.rb in fluent-plugin-newrelic-0.2.4

- old
+ new

@@ -77,18 +77,18 @@ packaged end def write(chunk) payload = { - 'logs' => [], 'common' => { 'attributes' => { 'plugin' => { 'type' => 'fluentd', 'version' => NewrelicFluentdOutput::VERSION, } } - } + }, + 'logs' => [] } chunk.msgpack_each do |ts, record| next unless record.is_a? Hash next if record.empty? payload['logs'].push(package_record(record, ts))