@Test
public void testStartExpiredQueueProcessing(TestContext context) {

    Mockito.when(lock.acquireLock(anyString(), anyString(), anyLong())).thenReturn(Future.succeededFuture(Boolean.TRUE));
    Mockito.when(lock.releaseLock(anyString(), anyString())).thenReturn(Future.succeededFuture(Boolean.TRUE));
    Mockito.when(reducedPropagationStorage.removeExpiredQueues(anyLong()))
            .thenReturn(Future.succeededFuture(new ArrayList<>()));
    manager.startExpiredQueueProcessing(10);
    verify(reducedPropagationStorage, timeout(110).atLeast(10)).removeExpiredQueues(anyLong());
}