@Override
  protected Pair<CompletableFuture, ExecutorService> startService() {
    LOG.info("Starting async archive service...");
    return Pair.of(CompletableFuture.supplyAsync(() -> {
      writeClient.archive();
      return true;
    }, executor), executor);
  }
@Test
  void startServiceShouldInvokeCallArchiveMethod() throws ExecutionException, InterruptedException {
    AsyncArchiveService service = new AsyncArchiveService(writeClient);
    assertEquals(true, service.startService().getLeft().get());
    verify(writeClient).archive();
  }