docs: public void start()
      {
          Preconditions.checkState(state.compareAndSet(State.LATENT, State.STARTED), "Cannot be started more than once");
  
          Preconditions.checkState(!executorService.isShutdown(), "Already started");
          Preconditions.checkState(!hasLeadership, "Already has leadership");
  
          client.getConnectionStateListenable().addListener(listener);
          requeue();
      }