@Test
public void testProcessIdentitiesFail() throws Exception {

  KerberosHelper kerberosHelper = injector.getInstance(KerberosHelper.class);
  expect(kerberosHelper.getKDCAdministratorCredentials(EasyMock.anyObject(String.class)))
      .andReturn(new PrincipalKeyCredential("principal", "password"))
      .anyTimes();
  replay(kerberosHelper);
  ConcurrentMap<String, Object> sharedMap = new ConcurrentHashMap<String, Object>();
  sharedMap.put("FAIL", "true");
  CommandReport report = action.processIdentities(sharedMap);
  Assert.assertNotNull(report);
  Assert.assertEquals(HostRoleStatus.FAILED.toString(), report.getStatus());
  verify(kerberosHelper);
}