fixed event emitter problem missed during 0.14->1.0 update

femueller · Apr 19, 2018 · debc460 · debc460
1 parent 4d4f210
commit debc460
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-0.8.3
+0.8.4
diff --git a/lib/fluent/plugin/out_scalyr.rb b/lib/fluent/plugin/out_scalyr.rb
@@ -29,6 +29,7 @@ module Scalyr
   class ScalyrOut < Fluent::Plugin::Output
     Fluent::Plugin.register_output( 'scalyr', self )
     helpers :compat_parameters
+    helpers :event_emitter
 
     config_param :api_write_token, :string
     config_param :server_attributes, :hash, :default => nil
@@ -321,8 +322,9 @@ def build_add_events_body( chunk )
         rescue JSON::GeneratorError, Encoding::UndefinedConversionError => e
           $log.warn "#{e.class}: #{e.message}"
 
-	  # Send the faulty event to a label @ERROR block and allow to handle it there (output to exceptions file for ex)
-	  router.emit_error_event(tag, time, record, e)
+          # Send the faulty event to a label @ERROR block and allow to handle it there (output to exceptions file for ex)
+          time = Fluent::EventTime.new( sec, nsec )
+          router.emit_error_event(tag, time, record, e)
 
           event[:attrs].each do |key, value|
             $log.debug "\t#{key} (#{value.encoding.name}): '#{value}'"