Add error logger to formatter class

lib/logstash-logger/formatter.rb

@@ -10,19 +10,19 @@ module Formatter
     autoload :Cee, 'logstash-logger/formatter/cee'
     autoload :CeeSyslog, 'logstash-logger/formatter/cee_syslog'
 
-    def self.new(formatter_type, customize_event: nil)
-      build_formatter(formatter_type, customize_event)
+    def self.new(formatter_type, customize_event: nil, error_logger: LogStashLogger.configuration.default_error_logger)
+      build_formatter(formatter_type, customize_event, error_logger)
     end
 
-    def self.build_formatter(formatter_type, customize_event)
+    def self.build_formatter(formatter_type, customize_event, error_logger)
       formatter_type ||= DEFAULT_FORMATTER
 
       formatter = if custom_formatter_instance?(formatter_type)
         formatter_type
       elsif custom_formatter_class?(formatter_type)
         formatter_type.new
       else
-        formatter_klass(formatter_type).new(customize_event: customize_event)
+        formatter_klass(formatter_type).new(customize_event: customize_event, error_logger: error_logger)
       end
 
       formatter.send(:extend, ::LogStashLogger::TaggedLogging::Formatter)

lib/logstash-logger/formatter/base.rb

@@ -7,10 +7,12 @@ module Formatter
     HOST = ::Socket.gethostname
 
     class Base < ::Logger::Formatter
+      attr_accessor :error_logger
       include ::LogStashLogger::TaggedLogging::Formatter
 
-      def initialize(customize_event: nil)
+      def initialize(customize_event: nil, error_logger: LogStashLogger.configuration.default_error_logger)
         @customize_event = customize_event
+        @error_logger = error_logger
         super()
       end
 
@@ -74,6 +76,10 @@ def force_utf8_encoding(event)
         event.message = original_message.force_encoding('UTF-8')
         event
       end
+
+      def log_error(e)
+        error_logger.error "[#{self.class}] #{e.class} - #{e.message}"
+      end
     end
   end
 end