@ApplicationScoped
public abstract class SimpleCachingLookupService<ID> implements ILookupService<ID>, IPlatformListener {

  private IFuture refreshFuture = null;
	
  public SimpleCachingLookupService(boolean enableScheduledRefresh) {
    this.scheduledRefreshEnabled = enableScheduledRefresh;
  }

  @Override
  public void stateChanged(PlatformEvent event) {
    if (isScheduledRefreshEnabled() &&
      event.getState() == IPlatform.State.PlatformStarted &&
      refreshFuture == null
      && !"GlobalTestingPlatform".equals(event.getSource().getClass().getSimpleName())
    ) {
      addScheduledRefreshJob();
      return;
    }
    if (isScheduledRefreshEnabled() &&
      event.getState() == IPlatform.State.PlatformStopping &&
      refreshFuture != null &&
      !refreshFuture.isCancelled()
    ) {
        refreshFuture.cancel(false);
    }
  }
  
  private void addScheduledRefreshJob() {
    if (isScheduledRefreshEnabled()) {
      refreshFuture = Jobs.schedule(() -> {
          if (RunMonitor.CURRENT.get().isCancelled()) {
            log.info("Job {} is cancelled", IFuture.CURRENT.get().getJobInput().getName());
            return;
          }
          forceRefresh();
        },
        Jobs.newInput()
          .withName(String.format("SimpleCachingLookupService(%s) Refresh Job", this.getClass().getSimpleName()))
          .withRunContext(ServerRunContexts.copyCurrent(true))
          .withExecutionTrigger(Jobs.newExecutionTrigger()
            .withSchedule(SimpleScheduleBuilder.simpleSchedule()
              .withIntervalInSeconds(getCacheTimeout())
              .repeatForever())));
      log.info("Scheduled {}, interval {} s", refreshFuture.getJobInput().getName(), getCacheTimeout());
    }
  }
  
  /* ... */
}