Restart runnable if error occurred and after deadline

RestartingRunnableService.java

private void start(Runnable consumer, long initialDelay, int step) {
    LOG.info("launching consumer {} ...", consumer.getClass().getCanonicalName());

    CompletableFuture<Object> promise = new CompletableFuture<>();
    LOG.info("delayed with: {}", initialDelay + step);
    scheduler.schedule(() -> promise.complete(null), initialDelay + step, TimeUnit.SECONDS);

    // waiting when promise completes
    CompletableFuture<Void> voidCompletableFuture = promise.thenRunAsync(consumer, executor)
      .exceptionally((t) -> {
        LOG.error("error h", t);
        return null;
      })
      .whenComplete((v, t) -> {
        // resubmit task
        LOG.info("restarting consumer {} ...", consumer.getClass().getCanonicalName());
        start(consumer, initialDelay + step, step);
      });

    scheduler.schedule(() -> {
      // stop
      voidCompletableFuture.cancel(true);
      // start
      start(consumer, initialDelay + step, step);
    }, 24, TimeUnit.HOURS);
  }