old_contents: """
  Logging Related Things
  
  """
  import logging
  
  
  class CorrelationFilter(logging.Formatter):
      """Filter records that have a correlation_id"""
      def __init__(self, exists=None):
          super(CorrelationFilter, self).__init__()
          self.exists = exists
  
      def filter(self, record):
          if self.exists:
              return hasattr(record, 'correlation_id')
          return not hasattr(record, 'correlation_id')
  
  
  class CorrelationAdapter(logging.LoggerAdapter):
      """A LoggerAdapter that appends the a correlation ID to the message
      record properties.
  
      """
      def __init__(self, logger, consumer):
          self.logger = logger
          self.consumer = consumer
  
      def process(self, msg, kwargs):
          """Process the logging message and keyword arguments passed in to
          a logging call to insert contextual information.
  
          :param str msg: The message to process
          :param dict kwargs: The kwargs to append
          :rtype: (str, dict)
  
          """
          kwargs['extra'] = {'correlation_id': self.consumer.correlation_id}
          return msg, kwargs
  
new_contents: """
  Logging Related Things
  
  """
  import logging
  
  
  class CorrelationFilter(logging.Formatter):
      """Filter records that have a correlation_id"""
      def __init__(self, exists=None):
          super(CorrelationFilter, self).__init__()
          self.exists = exists
  
      def filter(self, record):
          if self.exists:
              return hasattr(record, 'correlation_id')
          return not hasattr(record, 'correlation_id')
  
  
  class CorrelationAdapter(logging.LoggerAdapter):
      """A LoggerAdapter that appends the a correlation ID to the message
      record properties.
  
      """
      def __init__(self, logger, consumer):
          self.logger = logger
          self.consumer = consumer
  
      def process(self, msg, kwargs):
          """Process the logging message and keyword arguments passed in to
          a logging call to insert contextual information.
  
          :param str msg: The message to process
          :param dict kwargs: The kwargs to append
          :rtype: (str, dict)
  
          """
          kwargs['extra'] = {'correlation_id': self.consumer.correlation_id,
                             'consumer': self.consumer.name}
          return msg, kwargs
  
subject: Add the consumer name to the extra values