emit EventTime with log event

fluent · Jan 10, 2017 · 5b87737 · 5b87737
1 parent e313703
commit 5b87737
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/log.rb b/lib/fluent/log.rb
@@ -351,7 +351,7 @@ def event(level, args)
           record[key] = record[key].inspect unless record[key].respond_to?(:to_msgpack)
         }
         record['message'] = message.dup
-        @engine.push_log_event("#{LOG_EVENT_TAG_PREFIX}.#{level}", time.to_i, record)
+        @engine.push_log_event("#{LOG_EVENT_TAG_PREFIX}.#{level}", Fluent::EventTime.from_time(time), record)
       end
 
       return time, message