public void fixUnDeletedQueues() throws ReplicationException {
    for (Map.Entry<ServerName, List<ReplicationQueueId>> replicatorAndQueueIds : undeletedQueueIds
      .entrySet()) {
      ServerName replicator = replicatorAndQueueIds.getKey();
      for (ReplicationQueueId queueId : replicatorAndQueueIds.getValue()) {
        queueStorage.removeQueue(queueId);
      }
    }
    for (String peerId : undeletedHFileRefsPeerIds) {
      queueStorage.removePeerFromHFileRefs(peerId);
    }
  }
Check and fix undeleted replication queues for removed peerId.
hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/ReplicationChecker.java