module Kafka::TaggedLogger

Public Class Methods

new(logger) click to toggle source
# File lib/kafka/tagged_logger.rb, line 53
def self.new(logger)
  logger ||= Logger.new(nil)
  return logger if logger.respond_to?(:push_tags) # already included
  # Ensure we set a default formatter so we aren't extending nil!
  logger.formatter ||= Logger::Formatter.new
  logger.formatter.extend TaggedFormatter
  logger.extend(self)
end

Public Instance Methods

flush() click to toggle source
Calls superclass method
# File lib/kafka/tagged_logger.rb, line 66
def flush
  clear_tags!
  super if defined?(super)
end
tagged(*tags) { |self| ... } click to toggle source
# File lib/kafka/tagged_logger.rb, line 62
def tagged(*tags)
  formatter.tagged(*tags) { yield self }
end