code: def stop(self):
          
          if not self.isThreadsRunning:
              raise ThreadManagerException("Broker threads are already stopped")
          self.isThreadsRunning = False
          for client in self.clients:
              client.stop()
docs: !
          Stop all receving threads.