code: protected void beginReplicating() {
          Log.v(TAG, "submit startReplicating()");
          executor.submit(new Runnable() {
              @Override
              public void run() {
                  if (isRunning()) {
                      Log.v(TAG, "start startReplicating()");
                      initPendingSequences();
                      initDownloadsToInsert();
                      startChangeTracker();
                  }
                  // start replicator ...
              }
          });
      }
docs: Actual work of starting the replication process.