docs: public void setOnMastership(Runnable toBeRunOnMastership) {
          Preconditions.checkNotNull(toBeRunOnMastership, "mastership runnable is null");
          m_onMastership = toBeRunOnMastership;
          // If connector "replicated" property is set to true then every
          // replicated export stream is its own master
          if (m_runEveryWhere) {
              //export stream for run-everywhere clients doesn't need ack mailbox
              m_ackMailboxRefs.set(null);
              acceptMastership();
          }
      }