code: def _restart_thread(self):
          
          while self.running['restart_thread']:
              try:
                  endpoint = self.restart_q.get(timeout=.5)
              except TimeoutError:
                  continue
              log.info("_restart_thread(): Restarting Thread for endpoint %s",
                       endpoint)
              self.unsubscribe(endpoint)
              self.subscribe(endpoint)
docs: Restarts subscription threads if their connection drops.
          :return: