def METHOD_NAME(self, join=False):
    # type: (bool) -> None
    self.stop_subscribers(join=join)
    self._client.reset_products()
    if self.status == ServiceStatus.STOPPED:
        return
    forksafe.unregister(self.start_subscribers)
    atexit.unregister(self.METHOD_NAME)
    self.stop()