Unify error logging

lib/logstash-logger/configuration.rb

@@ -11,9 +11,11 @@ def configure(&block)
   class Configuration
     attr_accessor :customize_event_block
     attr_accessor :max_message_size
+    attr_accessor :default_error_logger
 
     def initialize(*args)
       @customize_event_block = nil
+      @default_error_logger = Logger.new($stderr)
 
       yield self if block_given?
       self

lib/logstash-logger/device/base.rb

@@ -3,9 +3,11 @@ module Device
     class Base
       attr_reader :io
       attr_accessor :sync
+      attr_accessor :error_logger
 
       def initialize(opts={})
         @sync = opts[:sync]
+        @error_logger = opts.fetch(:error_logger, LogStashLogger.configuration.default_error_logger)
       end
 
       def to_io
@@ -23,10 +25,20 @@ def flush
       def close
         @io && @io.close
       rescue => e
-        warn "#{self.class} - #{e.class} - #{e.message}"
+        log_error(e)
       ensure
         @io = nil
       end
+
+      private
+
+      def log_error(e)
+        error_logger.error "[#{self.class}] #{e.class} - #{e.message}"
+      end
+
+      def log_warning(message)
+        error_logger.warn("[#{self.class}] #{message}")
+      end
     end
   end
 end

lib/logstash-logger/device/connectable.rb

@@ -95,7 +95,7 @@ def with_connection(&block)
         connect unless connected?
         yield
       rescue => e
-        warn "#{self.class} - #{e.class} - #{e.message}"
+        log_error(e)
         @io = nil
         raise
       end

lib/logstash-logger/device/kafka.rb

@@ -36,12 +36,14 @@ def with_connection
         connect unless @io
         yield
       rescue ::Poseidon::Errors::ChecksumError, Poseidon::Errors::UnableToFetchMetadata => e
-        warn "#{self.class} - #{e.class} -> reconnect/retry"
+        log_error(e)
+        log_warning("reconnect/retry")
         sleep backoff if backoff
         reconnect
         retry
       rescue => e
-        warn "#{self.class} - #{e.class} - #{e.message} -> giving up"
+        log_error(e)
+        log_warning("giving up")
         @io = nil
       end
 
@@ -55,7 +57,7 @@ def close
         buffer_flush(final: true)
         @io && @io.close
       rescue => e
-        warn "#{self.class} - #{e.class} - #{e.message}"
+        log_error(e)
       ensure
         @io = nil
       end

lib/logstash-logger/device/redis.rb

@@ -32,7 +32,7 @@ def with_connection
         reconnect
         retry
       rescue => e
-        warn "#{self.class} - #{e.class} - #{e.message}"
+        log_error(e)
         @io = nil
         raise
       end
@@ -47,7 +47,7 @@ def close
         buffer_flush(final: true)
         @io && @io.quit
       rescue => e
-        warn "#{self.class} - #{e.class} - #{e.message}"
+        log_error(e)
       ensure
         @io = nil
       end