1 files changed, 44 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
new file mode 100644
index 0000000..0df5c68
--- /dev/null
+++ b/src/main/java/at/gv/egiz/moazs/backend/MsgResponseSinkHub.java
@@ -0,0 +1,44 @@
+package at.gv.egiz.moazs.backend;
+
+import at.gv.egiz.moazs.scheme.MsgResponse;
+import at.gv.zustellung.app2mzs.xsd.MsgResponseSinksType;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import static java.util.concurrent.CompletableFuture.supplyAsync;
+
+@Component
+public class MsgResponseSinkHub {
+
+    private final SaveResponseToFileSink saveResponseSink;
+    private final LogResponseSink logResponseSink;
+    private final ForwardResponseToServiceSink forwardResponseSink;
+
+    @Autowired
+    public MsgResponseSinkHub(SaveResponseToFileSink saveResponseSink, LogResponseSink logResponseSink,
+                              ForwardResponseToServiceSink forwardResponseSink) {
+        this.saveResponseSink = saveResponseSink;
+        this.logResponseSink = logResponseSink;
+        this.forwardResponseSink = forwardResponseSink;
+    }
+
+    /**
+     * Apply all sinks that are configured in {@code sinkParams} to {@code msgResponse}.
+     */
+    public void applySinks(MsgResponse msgResponse, MsgResponseSinksType sinkParams) {
+
+        if (sinkParams.getSaveResponseToFile().isActive()) {
+            supplyAsync(() -> saveResponseSink.save(msgResponse, sinkParams.getSaveResponseToFile().getPath()));
+        }
+
+        if (sinkParams.isLogResponse()) {
+            supplyAsync(() -> logResponseSink.log(msgResponse));
+        }
+
+        if (sinkParams.getForwardResponseToService().isActive()) {
+            supplyAsync(() -> forwardResponseSink.send(
+                    msgResponse, sinkParams.getForwardResponseToService().getMzsClient()));
+        }
+
+    }
+}