code: private HBaseQueueAdmin ensureTableExists(QueueName queueName) throws IOException {
      HBaseQueueAdmin admin = queueAdmin;
      try {
        if (!admin.exists(queueName)) {
          admin.create(queueName);
        }
      } catch (Exception e) {
        throw new IOException("Failed to open table " + admin.getActualTableName(queueName), e);
      }
      return admin;
    }
docs: Helper method to select the queue or stream admin, and to ensure it's table exists.
  @param queueName name of the queue to be opened.
  @return the queue admin for that queue.
  @throws java.io.IOException