lib/fluent/plugin/formatter_gelf.rb in fluent-plugin-gelf-hs-1.0.4 vs lib/fluent/plugin/formatter_gelf.rb in fluent-plugin-gelf-hs-1.0.5

@@ -2,10 +2,14 @@
 
 module Fluent
   module TextFormatter
     class GELFFormatter < Formatter
 
+      unless method_defined?(:log)
+        define_method('log') { $log }
+      end
+
       Plugin.register_formatter("gelf", self)
 
       require 'fluent/gelf_util'
       include GelfUtil
 
@@ -15,18 +19,29 @@
       def configure(conf)
         super(conf)
       end
 
       def format(tag, time, record)
-        gelfentry = make_gelfentry(
-          tag,time,record,
-          {
-            :use_record_host => @use_record_host,
-            :add_msec_time => @add_msec_time
-          }
-        )
 
-        make_json(gelfentry,{})
+        begin
+
+          gelfentry = make_gelfentry(
+            tag,time,record,
+            {
+              :use_record_host => @use_record_host,
+              :add_msec_time => @add_msec_time
+            }
+          )
+
+          make_json(gelfentry,{})
+      
+        rescue Exception => e
+          log.error sprintf(
+            'Error trying to serialize %s: %s',
+            record.to_s.force_encoding('UTF-8'),
+            e.message.to_s.force_encoding('UTF-8')
+          )
+        end
       end
 
     end
   end
 end