old_contents: from queue import Empty, Queue
  from threading import Thread, Event
  import logging
  
  from .checks import Check, IntervalCheck, ScheduledCheck
  from .notify import Notifier
  from .notify import TwilioNotifier
  from .notify import SMTPNotifier
  from .notify import Message
  from .notify import levels
  from .notify import TelegramNotifier
  from .notify import ConsoleNotifier
  from .notify import HTTPNotifier
  
  
  log = logging.getLogger(__name__)
  
  
  class Custos:
      '''
      The custos class holds checks and notifiers and sticks them together.
  
      '''
      def __init__(self, checks, notifiers):
          self.queue = Queue()
          self.notifiers = notifiers
          self.checks = checks
          for check in self.checks:
              check.queue = self.queue
          self.stop_event = Event()
  
      def start(self):
          for check in self.checks:
              check.start()
  
          log.info('%s running', self.__class__.__name__)
  
      def run(self):
          self.start()
          while not self.stop_event.is_set():
              try:
                  message = self.queue.get(block=True, timeout=1)
                  print(message.text)
              except Empty:
                  continue
  
              for notifier in self.notifiers:
                  try:
                      notifier.handle_message(message)
                  except (KeyboardInterrupt, SystemExit):
                      raise
                  except:
                      log.exception(
                          '%s failed to handle message',
                          notifier.__class__.__name__
                      )
  
      def stop(self):
          for check in self.checks:
              check.stop()
          self.stop_event.set()
          log.info('%s stopped', self.__class__.__name__)
  
      def __enter__(self):
          return self
  
      def __exit__(self, exc_type, exc_value, traceback):
          self.stop()
  
new_contents: from queue import Empty, Queue
  from threading import Thread, Event
  import logging
  
  from .checks import Check, IntervalCheck, ScheduledCheck
  from .notify import Notifier
  from .notify import TwilioNotifier
  from .notify import SMTPNotifier
  from .notify import Message
  from .notify import levels
  from .notify import TelegramNotifier
  from .notify import ConsoleNotifier
  from .notify import HTTPNotifier
  
  
  log = logging.getLogger(__name__)
  
  
  class Custos:
      '''
      The custos class holds checks and notifiers and sticks them together.
  
      '''
      def __init__(self, checks, notifiers):
          self.queue = Queue()
          self.notifiers = notifiers
          self.checks = checks
          for check in self.checks:
              check.queue = self.queue
          self.stop_event = Event()
  
      def start(self):
          for check in self.checks:
              check.start()
  
          log.info('%s running', self.__class__.__name__)
  
      def run(self):
          self.start()
          while not self.stop_event.is_set():
              try:
                  message = self.queue.get(block=True, timeout=1)
              except Empty:
                  continue
  
              for notifier in self.notifiers:
                  try:
                      notifier.handle_message(message)
                  except (KeyboardInterrupt, SystemExit):
                      raise
                  except:
                      log.exception(
                          '%s failed to handle message',
                          notifier.__class__.__name__
                      )
  
      def stop(self):
          for check in self.checks:
              check.stop()
          self.stop_event.set()
          log.info('%s stopped', self.__class__.__name__)
  
      def __enter__(self):
          return self
  
      def __exit__(self, exc_type, exc_value, traceback):
          self.stop()
  
subject: remove print