private void cleanupQueuesWithoutRegionReplicaReplication(ServerName serverName)
        throws Exception {
        String rsZNode = getRsNode(serverName);
        List<String> queueIdList = ZKUtil.listChildrenNoWatch(zookeeper, rsZNode);
        if (CollectionUtils.isEmpty(queueIdList)) {
          return;
        }
        for (String queueId : queueIdList) {
          ReplicationQueueInfo queueInfo = new ReplicationQueueInfo(queueId);
          if (!queueInfo.getPeerId().equals(REGION_REPLICA_REPLICATION_PEER)) {
            ZKUtil.deleteNodeRecursively(zookeeper, getQueueNode(serverName, queueId));
          }
        }
      }
The name of the znode that contains queues of hfile references to be replicated
hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorageForMigration.java