import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
-import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
scheduledExecutorService.schedule(() -> {
MainTask worker = new MainTask(jobEntry);
fjPool.execute(worker);
- }, waitTime, TimeUnit.MILLISECONDS);
+ }, waitTime, TimeUnit.MILLISECONDS);
return;
}
continue;
}
LOG.trace("JobQueueHandler handling queue {} with kesy size {}. Keys: {} ", i,
- jobEntriesMap.size(), Arrays.toString(jobEntriesMap.keySet().toArray()));
+ jobEntriesMap.size(), jobEntriesMap.keySet());
synchronized (jobEntriesMap) {
Iterator<Map.Entry<String, JobQueue>> it = jobEntriesMap.entrySet().iterator();