InstanceFactory.getInstance(ScheduledExecutorService.class).schedule(new Callable<Object>() { @Override public Object call() throws Exception { doFinish(instanceId, tag); return null; }}, 5, TimeUnit.SECONDS);