code: def run(self):
          
          if not self._queue:
              raise Exception("No queue available to send messages")
  
          while True:
              self.fetch()
              time.sleep(self._pause)
docs: Called by the process, it runs it.
  
          NEVER call this method directly. Instead call start() to start the separate process.
          If you don't want to use a second process, then call fetch() directly on this istance.
  
          To stop, call terminate()