def _restart_thread(self):
        """
        Restarts subscription threads if their connection drops.
        :return:
        """
        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)
Restarts subscription threads if their connection drops.
        :return: