+ public Future<Void> tryFinishProcessing() {
+ executorService = Executors.newSingleThreadScheduledExecutor();
+ final SettableFuture<Void> settableFuture = SettableFuture.create();
+
+ scheduledFuture = executorService.scheduleAtFixedRate(new CheckFinishedTask(settableFuture),
+ 0, 1, TimeUnit.SECONDS);
+ return settableFuture;
+ }
+