lib/fluent/plugin/out_mixpanel.rb in fluent-plugin-mixpanel-0.0.7 vs lib/fluent/plugin/out_mixpanel.rb in fluent-plugin-mixpanel-0.0.8
- old
+ new
@@ -46,9 +46,10 @@
def shutdown
super
end
def format(tag, time, record)
+ time = record['time'] if record['time'] && @use_import
[tag, time, record].to_msgpack
end
def write(chunk)
records = []