public void shutdown() {
    if (!scheduler.isTerminated()) {
      logger.info("Shutting down ReplicationPrioritizationManager");
      Utils.shutDownExecutorService(scheduler, 5, TimeUnit.SECONDS);
      // clear all maps
      currentlyReplicatingPriorityPartitions.clear();
      disabledReplicationPartitions.clear();
      allBootstrappingPartitions.clear();
      completedPartitions.clear();
      prioritizedPartitions.clear();
      isHighPriorityReplicationRunning.set(false);
    } else {
      logger.info("ReplicationPrioritizationManager already shut down");
    }
  }
Main entry point for the replication prioritization manager.
ambry-prioritization/src/main/java/com/github/ambry/replica/prioritization/ReplicationPrioritizationManager.java