WorkQueueRepository.LongRunningProcessMessage longRunningProcessMessage = workQueueRepository.getNextLongRunningProcessMessage();
if (longRunningProcessMessage == null) {
continue;
}
try {
longRunningProcessRunner.process(longRunningProcessMessage.getMessage());
longRunningProcessMessage.complete();
} catch (Throwable ex) {
LOGGER.error("Failed to process long running process: %s", longRunningProcessMessage.getMessage());
longRunningProcessMessage.complete(ex);
}