@Test
public void testRefreshQueues() throws Exception {

  String[] args = { "-refreshQueues" };
  assertEquals(0, rmAdminCLI.run(args));
  verify(admin).refreshQueues(any(RefreshQueuesRequest.class));
}