private void retryRefreshing(Thread t, Throwable error) {
    checkError(t, error);
    while (true) {
      if (server.isAborted() || server.isStopped() || server.isStopping()) {
        LOG.warn("Server is shutting down, give up refreshing source for peer {}", getPeerId());
        return;
      }
      try {
        LOG.info("Refreshing replication sources now due to previous error on thread: {}",
          t.getName());
        manager.refreshSources(getPeerId());
        break;
      } catch (Exception e) {
        LOG.error("Replication sources refresh failed.", e);
        sleepForRetries("Sleeping before try refreshing sources again", maxRetriesMultiplier);
      }
    }
  }
Call after {@link #initializeWALEntryFilter(UUID)} else it will be null.
@return WAL Entry Filter Chain to use on WAL files filtering *out* WALEntry edits.
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java