Ensure that Each Step of Each Backend Process is Logged

1 files changed, 7 insertions, 0 deletions

diff --git a/src/main/java/at/gv/egiz/moazs/backend/MsgResponseSinkHub.java b/src/main/java/at/gv/egiz/moazs/backend/MsgResponseSinkHub.java
index 0df5c68..46b0101 100644
--- a/src/main/java/at/gv/egiz/moazs/backend/MsgResponseSinkHub.java
+++ b/src/main/java/at/gv/egiz/moazs/backend/MsgResponseSinkHub.java
@@ -2,6 +2,8 @@ package at.gv.egiz.moazs.backend;
 
 import at.gv.egiz.moazs.scheme.MsgResponse;
 import at.gv.zustellung.app2mzs.xsd.MsgResponseSinksType;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -10,6 +12,8 @@ import static java.util.concurrent.CompletableFuture.supplyAsync;
 @Component
 public class MsgResponseSinkHub {
 
+    private static final Logger log = LoggerFactory.getLogger(MsgResponseSinkHub.class);
+
     private final SaveResponseToFileSink saveResponseSink;
     private final LogResponseSink logResponseSink;
     private final ForwardResponseToServiceSink forwardResponseSink;
@@ -27,6 +31,9 @@ public class MsgResponseSinkHub {
      */
     public void applySinks(MsgResponse msgResponse, MsgResponseSinksType sinkParams) {
 
+        log.info("Apply Sinks to msg:{} with appDeliveryID={}.",
+                msgResponse.getRootElementLocalPart(), msgResponse.getAppDeliveryID());
+
         if (sinkParams.getSaveResponseToFile().isActive()) {
             supplyAsync(() -> saveResponseSink.save(msgResponse, sinkParams.getSaveResponseToFile().getPath()));
         }