private void releaseQueuedTask(final Set<Long> taskIdSet) {
        if (!taskIdSet.isEmpty()) {
            try {
                processorTaskDao.releaseTasks(taskIdSet, TaskStatus.QUEUED);
            } catch (final RuntimeException e) {
                LOGGER.error("release() - {}", taskIdSet, e);
            }
        }
    }
Return the next task to perform. Called by worker threads. Also assigns
the task to the node asking for the job
stroom-processor/stroom-processor-impl/src/main/java/stroom/processor/impl/ProcessorTaskQueueManagerImpl.java