private int refreshClusterMaxPriority(String subClusterId) throws IOException, YarnException {
    // Refresh cluster max priority
    ResourceManagerAdministrationProtocol adminProtocol = createAdminProtocol();
    RefreshClusterMaxPriorityRequest request =
        recordFactory.newRecordInstance(RefreshClusterMaxPriorityRequest.class);
    if (StringUtils.isNotBlank(subClusterId)) {
      request.setSubClusterId(subClusterId);
    }
    adminProtocol.refreshClusterMaxPriority(request);
    return 0;
  }
@Test
  public void testRefreshClusterMaxPriority() throws Exception {
    String[] args = { "-refreshClusterMaxPriority" };
    assertEquals(0, rmAdminCLI.run(args));
    verify(admin).refreshClusterMaxPriority(
        any(RefreshClusterMaxPriorityRequest.class));
  }