@VisibleForTesting
  void createPersistentBucketRecoverer(int proxyBuckets) {
    persistentBucketRecoverer = persistentBucketRecovererFunction.apply(this, proxyBuckets);
    persistentBucketRecoverer.startLoggingThread();
  }
Schedule a task to perform redundancy recovery for a new node or for the node departed.
geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java