diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/logging/ErrorLogger.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/logging/ErrorLogger.java index 8dd25985..d9eee869 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/logging/ErrorLogger.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/logging/ErrorLogger.java @@ -7,11 +7,35 @@ public class ErrorLogger { private static final Logger validationLogger = LoggerFactory.getLogger("validation-error-logger"); + private static final Logger errorLogger = LoggerFactory.getLogger("error-logger"); public void logValidationFailed(IdType taskId) { - validationLogger.debug( - "Validation of FHIR resources faild during execution of data-send process started by Task {}", - taskId.getValue()); + validationLogger.debug("Validation of FHIR resources failed, started by Task {}", taskId.getValue()); + } + + public void logValidationFailedLocal(IdType taskId) + { + validationLogger.debug("Local validation of FHIR resources failed, started by Task {}", taskId.getValue()); + } + + public void logValidationFailedRemote(IdType taskId) + { + validationLogger.debug("Remote validation of FHIR resources failed, started by Task {}", taskId.getValue()); + } + + public void logDataSendFailed(IdType taskId) + { + errorLogger.debug("Send process failed, started by Task {}", taskId.getValue()); + } + + public void logDataTranslateFailed(IdType taskId) + { + errorLogger.debug("Translate process failed, started by Task {}", taskId.getValue()); + } + + public void logDataReceiveFailed(IdType taskId) + { + errorLogger.debug("Receive process failed, started by Task {}", taskId.getValue()); } } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogError.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogError.java index 3046f967..12900e97 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogError.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogError.java @@ -14,6 +14,7 @@ import org.highmed.dsf.fhir.authorization.read.ReadAccessHelper; import org.highmed.dsf.fhir.client.FhirWebserviceClientProvider; import org.highmed.dsf.fhir.task.TaskHelper; +import org.hl7.fhir.r4.model.ResourceType; import org.hl7.fhir.r4.model.Task; import org.hl7.fhir.r4.model.Task.TaskOutputComponent; import org.hl7.fhir.r4.model.Task.TaskStatus; @@ -21,19 +22,23 @@ import org.slf4j.LoggerFactory; import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.error.ErrorOutputParameterGenerator; +import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.logging.ErrorLogger; public class LogError extends AbstractServiceDelegate { private static final Logger logger = LoggerFactory.getLogger(LogError.class); private final ErrorOutputParameterGenerator errorOutputParameterGenerator; + private final ErrorLogger errorLogger; public LogError(FhirWebserviceClientProvider clientProvider, TaskHelper taskHelper, - ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator) + ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator, + ErrorLogger errorLogger) { super(clientProvider, taskHelper, readAccessHelper); this.errorOutputParameterGenerator = errorOutputParameterGenerator; + this.errorLogger = errorLogger; } @Override @@ -42,6 +47,7 @@ public void afterPropertiesSet() throws Exception super.afterPropertiesSet(); Objects.requireNonNull(errorOutputParameterGenerator, "errorOutputParameterGenerator"); + Objects.requireNonNull(errorLogger, "errorLogger"); } @Override @@ -63,6 +69,11 @@ protected void doExecute(DelegateExecution execution) throws BpmnError, Exceptio errorCode, errorMessage); task.addOutput(output); + + logger.warn("Error while transfering data to CRR: {} - {}", errorCode, errorMessage); + + errorLogger.logDataReceiveFailed(getLeadingTaskFromExecutionVariables().getIdElement() + .withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name())); } } } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogValidationError.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogValidationError.java index faa2ca31..950c05c8 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogValidationError.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/receive/LogValidationError.java @@ -13,25 +13,30 @@ import org.hl7.fhir.r4.model.Bundle; import org.hl7.fhir.r4.model.OperationOutcome; import org.hl7.fhir.r4.model.OperationOutcome.IssueSeverity; +import org.hl7.fhir.r4.model.ResourceType; import org.hl7.fhir.r4.model.Task; import org.hl7.fhir.r4.model.Task.TaskStatus; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.error.ErrorOutputParameterGenerator; +import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.logging.ErrorLogger; public class LogValidationError extends AbstractServiceDelegate { private static final Logger logger = LoggerFactory.getLogger(LogValidationError.class); private final ErrorOutputParameterGenerator errorOutputParameterGenerator; + private final ErrorLogger errorLogger; public LogValidationError(FhirWebserviceClientProvider clientProvider, TaskHelper taskHelper, - ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator) + ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator, + ErrorLogger errorLogger) { super(clientProvider, taskHelper, readAccessHelper); this.errorOutputParameterGenerator = errorOutputParameterGenerator; + this.errorLogger = errorLogger; } @Override @@ -40,11 +45,16 @@ public void afterPropertiesSet() throws Exception super.afterPropertiesSet(); Objects.requireNonNull(errorOutputParameterGenerator, "errorOutputParameterGenerator"); + Objects.requireNonNull(errorLogger, "errorLogger"); } @Override protected void doExecute(DelegateExecution execution) throws BpmnError, Exception { + logger.info("Validation error while adding resources to CRR FHIR repository"); + errorLogger.logValidationFailed(getLeadingTaskFromExecutionVariables().getIdElement() + .withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name())); + logger.debug("Setting Task.status failed, adding validation errors"); Task task = getLeadingTaskFromExecutionVariables(); diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogError.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogError.java index 5b5e6a56..2ce4145c 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogError.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogError.java @@ -14,6 +14,7 @@ import org.highmed.dsf.fhir.authorization.read.ReadAccessHelper; import org.highmed.dsf.fhir.client.FhirWebserviceClientProvider; import org.highmed.dsf.fhir.task.TaskHelper; +import org.hl7.fhir.r4.model.ResourceType; import org.hl7.fhir.r4.model.Task; import org.hl7.fhir.r4.model.Task.TaskOutputComponent; import org.hl7.fhir.r4.model.Task.TaskStatus; @@ -21,19 +22,23 @@ import org.slf4j.LoggerFactory; import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.error.ErrorOutputParameterGenerator; +import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.logging.ErrorLogger; public class LogError extends AbstractServiceDelegate { private static final Logger logger = LoggerFactory.getLogger(LogError.class); private final ErrorOutputParameterGenerator errorOutputParameterGenerator; + private final ErrorLogger errorLogger; public LogError(FhirWebserviceClientProvider clientProvider, TaskHelper taskHelper, - ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator) + ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator, + ErrorLogger errorLogger) { super(clientProvider, taskHelper, readAccessHelper); this.errorOutputParameterGenerator = errorOutputParameterGenerator; + this.errorLogger = errorLogger; } @Override @@ -42,6 +47,7 @@ public void afterPropertiesSet() throws Exception super.afterPropertiesSet(); Objects.requireNonNull(errorOutputParameterGenerator, "errorOutputParameterGenerator"); + Objects.requireNonNull(errorLogger, "errorLogger"); } @Override @@ -63,6 +69,11 @@ protected void doExecute(DelegateExecution execution) throws BpmnError, Exceptio errorCode, errorMessage); task.addOutput(output); + + logger.warn("Error while transfering data to CRR: {} - {}", errorCode, errorMessage); + + errorLogger.logDataReceiveFailed(getLeadingTaskFromExecutionVariables().getIdElement() + .withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name())); } } } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogSuccess.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogSuccess.java index 988c31bf..193b2a43 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogSuccess.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogSuccess.java @@ -22,7 +22,6 @@ public LogSuccess(FhirWebserviceClientProvider clientProvider, TaskHelper taskHe @Override protected void doExecute(DelegateExecution execution) throws BpmnError, Exception { - // TODO log success - logger.debug("TODO log success"); + logger.info("All resources successfully added to CRR FHIR repository"); } } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogValidationError.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogValidationError.java index 96faf3b4..a7ac6852 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogValidationError.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogValidationError.java @@ -18,6 +18,7 @@ import org.hl7.fhir.r4.model.OperationOutcome; import org.hl7.fhir.r4.model.OperationOutcome.IssueSeverity; import org.hl7.fhir.r4.model.OperationOutcome.OperationOutcomeIssueComponent; +import org.hl7.fhir.r4.model.ResourceType; import org.hl7.fhir.r4.model.StringType; import org.hl7.fhir.r4.model.Task; import org.hl7.fhir.r4.model.Task.TaskStatus; @@ -25,19 +26,23 @@ import org.slf4j.LoggerFactory; import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.error.ErrorOutputParameterGenerator; +import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.logging.ErrorLogger; public class LogValidationError extends AbstractServiceDelegate { private static final Logger logger = LoggerFactory.getLogger(LogValidationError.class); private final ErrorOutputParameterGenerator errorOutputParameterGenerator; + private final ErrorLogger errorLogger; public LogValidationError(FhirWebserviceClientProvider clientProvider, TaskHelper taskHelper, - ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator) + ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator, + ErrorLogger errorLogger) { super(clientProvider, taskHelper, readAccessHelper); this.errorOutputParameterGenerator = errorOutputParameterGenerator; + this.errorLogger = errorLogger; } @Override @@ -46,17 +51,22 @@ public void afterPropertiesSet() throws Exception super.afterPropertiesSet(); Objects.requireNonNull(errorOutputParameterGenerator, "errorOutputParameterGenerator"); + Objects.requireNonNull(errorLogger, "errorLogger"); } @Override protected void doExecute(DelegateExecution execution) throws BpmnError, Exception { + logger.info("Validation error while adding resources to CRR FHIR repository"); + Bundle bundle = (Bundle) execution.getVariable(BPMN_EXECUTION_VARIABLE_BUNDLE); @SuppressWarnings("unchecked") Map sourceIdsByBundleUuid = (Map) execution .getVariable(BPMN_EXECUTION_VARIABLE_SOURCE_IDS_BY_BUNDLE_UUID); + errorLogger.logValidationFailedRemote(getLeadingTaskFromExecutionVariables().getIdElement() + .withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name())); logValidationDetails(bundle, sourceIdsByBundleUuid); addErrorsToTask(bundle, sourceIdsByBundleUuid); } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/ValidateData.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/ValidateData.java index 393c67e2..205323cb 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/ValidateData.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/ValidateData.java @@ -23,6 +23,7 @@ import org.hl7.fhir.r4.model.OperationOutcome; import org.hl7.fhir.r4.model.OperationOutcome.IssueSeverity; import org.hl7.fhir.r4.model.OperationOutcome.OperationOutcomeIssueComponent; +import org.hl7.fhir.r4.model.ResourceType; import org.hl7.fhir.r4.model.StringType; import org.hl7.fhir.r4.model.Task; import org.slf4j.Logger; @@ -112,9 +113,9 @@ protected void doExecute(DelegateExecution execution) throws BpmnError, Exceptio resourcesWithErrorCount, resourcesWithErrorCount != 1 ? "s" : ""); addErrorsToTask(bundle); - errorLogger.logValidationFailed(getLeadingTaskFromExecutionVariables().getIdElement() - .withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), - getLeadingTaskFromExecutionVariables().getIdElement().getResourceType())); + errorLogger.logValidationFailedLocal( + getLeadingTaskFromExecutionVariables().getIdElement().withServerBase( + getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name())); throw new BpmnError(CODESYSTEM_NUM_CODEX_DATA_TRANSFER_ERROR_VALUE_VALIDATION_FAILED, "Validation of transfer bundle failed, " + resourcesWithErrorCount + " resource" diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogError.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogError.java index 4da488f9..5aad5e7e 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogError.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogError.java @@ -14,6 +14,7 @@ import org.highmed.dsf.fhir.authorization.read.ReadAccessHelper; import org.highmed.dsf.fhir.client.FhirWebserviceClientProvider; import org.highmed.dsf.fhir.task.TaskHelper; +import org.hl7.fhir.r4.model.ResourceType; import org.hl7.fhir.r4.model.Task; import org.hl7.fhir.r4.model.Task.TaskOutputComponent; import org.hl7.fhir.r4.model.Task.TaskStatus; @@ -21,19 +22,23 @@ import org.slf4j.LoggerFactory; import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.error.ErrorOutputParameterGenerator; +import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.logging.ErrorLogger; public class LogError extends AbstractServiceDelegate { private static final Logger logger = LoggerFactory.getLogger(LogError.class); private final ErrorOutputParameterGenerator errorOutputParameterGenerator; + private final ErrorLogger errorLogger; public LogError(FhirWebserviceClientProvider clientProvider, TaskHelper taskHelper, - ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator) + ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator, + ErrorLogger errorLogger) { super(clientProvider, taskHelper, readAccessHelper); this.errorOutputParameterGenerator = errorOutputParameterGenerator; + this.errorLogger = errorLogger; } @Override @@ -42,6 +47,7 @@ public void afterPropertiesSet() throws Exception super.afterPropertiesSet(); Objects.requireNonNull(errorOutputParameterGenerator, "errorOutputParameterGenerator"); + Objects.requireNonNull(errorLogger, "errorLogger"); } @Override @@ -63,6 +69,11 @@ protected void doExecute(DelegateExecution execution) throws BpmnError, Exceptio errorCode, errorMessage); task.addOutput(output); + + logger.warn("Error while transfering data to CRR: {} - {}", errorCode, errorMessage); + + errorLogger.logDataReceiveFailed(getLeadingTaskFromExecutionVariables().getIdElement() + .withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name())); } } } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogValidationError.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogValidationError.java index bb6981d9..9eea9f05 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogValidationError.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogValidationError.java @@ -11,25 +11,30 @@ import org.highmed.dsf.fhir.authorization.read.ReadAccessHelper; import org.highmed.dsf.fhir.client.FhirWebserviceClientProvider; import org.highmed.dsf.fhir.task.TaskHelper; +import org.hl7.fhir.r4.model.ResourceType; import org.hl7.fhir.r4.model.Task; import org.hl7.fhir.r4.model.Task.TaskOutputComponent; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.error.ErrorOutputParameterGenerator; +import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.logging.ErrorLogger; public class LogValidationError extends AbstractServiceDelegate { private static final Logger logger = LoggerFactory.getLogger(LogValidationError.class); private final ErrorOutputParameterGenerator errorOutputParameterGenerator; + private final ErrorLogger errorLogger; public LogValidationError(FhirWebserviceClientProvider clientProvider, TaskHelper taskHelper, - ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator) + ReadAccessHelper readAccessHelper, ErrorOutputParameterGenerator errorOutputParameterGenerator, + ErrorLogger errorLogger) { super(clientProvider, taskHelper, readAccessHelper); this.errorOutputParameterGenerator = errorOutputParameterGenerator; + this.errorLogger = errorLogger; } @Override @@ -38,12 +43,15 @@ public void afterPropertiesSet() throws Exception super.afterPropertiesSet(); Objects.requireNonNull(errorOutputParameterGenerator, "errorOutputParameterGenerator"); + Objects.requireNonNull(errorLogger, "errorLogger"); } @Override protected void doExecute(DelegateExecution execution) throws BpmnError, Exception { logger.info("Validation error while adding resources to CRR FHIR repository"); + errorLogger.logValidationFailedRemote(getLeadingTaskFromExecutionVariables().getIdElement() + .withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name())); Task task = getLeadingTaskFromExecutionVariables(); TaskOutputComponent output = errorOutputParameterGenerator.createError( diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/ReceiveConfig.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/ReceiveConfig.java index b0496b7c..aafe8620 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/ReceiveConfig.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/ReceiveConfig.java @@ -66,7 +66,8 @@ public LogSuccess logSuccess() public LogValidationError logValidationError() { return new LogValidationError(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(), - transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator()); + transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator(), + transferDataConfig.errorLogger()); } @Bean @@ -112,6 +113,7 @@ public ContinueTranslateProcessWithError continueTranslateProcessWithError() public LogError logError() { return new LogError(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(), - transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator()); + transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator(), + transferDataConfig.errorLogger()); } } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/SendConfig.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/SendConfig.java index 6d0cf06f..dafcf9b2 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/SendConfig.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/SendConfig.java @@ -154,13 +154,15 @@ public LogSuccess logSuccess() public LogValidationError logValidationError() { return new LogValidationError(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(), - transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator()); + transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator(), + transferDataConfig.errorLogger()); } @Bean(name = "Send-logError") // prefix to force distinct bean names public LogError logError() { return new LogError(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(), - transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator()); + transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator(), + transferDataConfig.errorLogger()); } } diff --git a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/TranslateConfig.java b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/TranslateConfig.java index f0304d49..21c92b64 100644 --- a/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/TranslateConfig.java +++ b/codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/TranslateConfig.java @@ -119,7 +119,8 @@ public ContinueSendProcessWithValidationError continueSendProcessWithValidationE public LogValidationError logValidationError() { return new LogValidationError(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(), - transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator()); + transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator(), + transferDataConfig.errorLogger()); } @Bean @@ -142,6 +143,7 @@ public ContinueSendProcessWithError continueSendProcessWithError() public LogError logError() { return new LogError(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(), - transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator()); + transferDataConfig.readAccessHelper(), transferDataConfig.errorOutputParameterGenerator(), + transferDataConfig.errorLogger()); } }