protected final ReplicationSourceShipper createNewShipper(String walGroupId) {
    ReplicationSourceWALReader walReader =
      createNewWALReader(walGroupId, getStartOffset(walGroupId));
    ReplicationSourceShipper worker = createNewShipper(walGroupId, walReader);
    Threads.setDaemonThreadRunning(walReader, Thread.currentThread().getName()
      + ".replicationSource.wal-reader." + walGroupId + "," + queueId, this::retryRefreshing);
    return worker;
  }
Instantiation method used by region servers
@param conf      configuration to use
@param fs        file system to use
@param manager   replication manager to ping to
@param server    the server for this region server
@param queueData the id and offsets of our replication queue
@param clusterId unique UUID for the cluster
@param metrics   metrics for replication source
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java