@Test
public void schedule() {

    TestDelayedTask task = new TestDelayedTask();
    consumerClient.schedule(task, time.milliseconds());
    consumerClient.poll(0);
    assertEquals(1, task.executions);
    consumerClient.schedule(task, time.milliseconds() + 100);
    consumerClient.poll(0);
    assertEquals(1, task.executions);
    time.sleep(100);
    consumerClient.poll(0);
    assertEquals(2, task.executions);
}