Skip to content
Snippets Groups Projects
Commit 3d2374d5 authored by OZGCloud's avatar OZGCloud
Browse files

OZG-4390 catch exception in listener to allow creation of vorgang

parent c0160830
No related branches found
No related tags found
No related merge requests found
#
# Copyright (C) 2022 Das Land Schleswig-Holstein vertreten durch den
# Ministerpräsidenten des Landes Schleswig-Holstein
# Staatskanzlei
# Abteilung Digitalisierung und zentrales IT-Management der Landesregierung
#
# Lizenziert unter der EUPL, Version 1.2 oder - sobald
# diese von der Europäischen Kommission genehmigt wurden -
# Folgeversionen der EUPL ("Lizenz");
# Sie dürfen dieses Werk ausschließlich gemäß
# dieser Lizenz nutzen.
# Eine Kopie der Lizenz finden Sie hier:
#
# https://joinup.ec.europa.eu/collection/eupl/eupl-text-eupl-12
#
# Sofern nicht durch anwendbare Rechtsvorschriften
# gefordert oder in schriftlicher Form vereinbart, wird
# die unter der Lizenz verbreitete Software "so wie sie
# ist", OHNE JEGLICHE GEWÄHRLEISTUNG ODER BEDINGUNGEN -
# ausdrücklich oder stillschweigend - verbreitet.
# Die sprachspezifischen Genehmigungen und Beschränkungen
# unter der Lizenz sind dem Lizenztext zu entnehmen.
#
lombok.log.fieldName=LOG
lombok.log.slf4j.flagUsage = ERROR
lombok.log.log4j.flagUsage = ERROR
lombok.data.flagUsage = ERROR
lombok.nonNull.exceptionType = IllegalArgumentException
lombok.addLombokGeneratedAnnotation = true
\ No newline at end of file
......@@ -7,11 +7,13 @@ import org.springframework.stereotype.Component;
import de.itvsh.ozg.pluto.command.VorgangCreatedEvent;
import de.ozgcloud.processor.processor.ProcessorService;
import lombok.RequiredArgsConstructor;
import lombok.extern.log4j.Log4j2;
import reactor.core.publisher.Mono;
@Component("processorVorgangEventListener")
@ConditionalOnProperty(prefix = "ozgcloud.processors[0]", name = "address")
@RequiredArgsConstructor
@Log4j2
class VorgangEventListener {
private final VorgangService service;
......@@ -19,7 +21,11 @@ class VorgangEventListener {
@EventListener
public void triggerNewVorgangProcessors(VorgangCreatedEvent event) {
try {
var vorgang = service.getVorgang(VorgangId.from(event.getSource()));
var results = processorService.processVorgang(vorgang).map(Mono::block).toList();
} catch (RuntimeException e) {
LOG.error("Error processing Vorgang in external Processor.", e);
}
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment