public int getQueueSize(String walGroupId) {
    Queue<Path> queue = queues.get(walGroupId);
    if (queue == null) {
      return 0;
    }
    return queue.size();
  }
Get the queue size for the given walGroupId.
@param walGroupId walGroupId
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceLogQueue.java