@Test
public void testDoRecovery() throws Exception {

    Assert.assertEquals(2,workerRecoveryListeners.size());
    workerRecoveryManager.doRecovery();
    verify(workerRecoveryListeners.get(0),times(1)).doRecovery();
    verify(workerRecoveryListeners.get(1),times(1)).doRecovery();
}