code: public static QueueName getQueueName(String appName, String flowName,
                                         byte[] rowBuffer, int rowOffset, int rowLength) {
      // Entry key is always (salt bytes + 1 MD5 byte + queueName + longWritePointer + intCounter)
      int queueNameEnd = rowOffset + rowLength - Bytes.SIZEOF_LONG - Bytes.SIZEOF_INT;
  
      // <flowlet><source>
      byte[] idWithinFlow = Arrays.copyOfRange(rowBuffer,
                                               rowOffset + HBaseQueueAdmin.SALT_BYTES + 1,
                                               queueNameEnd);
      String idWithinFlowAsString = new String(idWithinFlow, Charsets.US_ASCII);
      // <flowlet><source>
      String[] parts = idWithinFlowAsString.split("/");
  
      return QueueName.fromFlowlet(appName, flowName, parts[0], parts[1]);
    }
docs: Extracts the queue name from the KeyValue row, which the row must be a queue entry.