def METHOD_NAME(self) -> None:
    try:
        while not self.shutdown.is_set():
            try:
                self.run_once()
            except queue.Empty:
                pass
    except KeyboardInterrupt:
        pass
    except Exception as e:
        logger.exception('Dispatcher exception', exc_info=e)
    finally:
        # Send shutdown message to all active subscribers
        self._broadcast({
            'event_name': eventNames.DISPATCHER_SHUTDOWN,
        })
        logger.info('Dispatcher shutdown')