def _reset(self):
        """Initialization that must happen before the broker is (re)started."""
        self._subscriber_thread = None
        self._must_stop = threading.Event()
        self._number_periodic_tasks = 0
def _reset ( self ) : self . _subscriber_thread = None self . _must_stop = threading . Event ( ) self . _number_periodic_tasks = 0
Initialization that must happen before the broker is (re)started.