1 files changed, 6 insertions, 5 deletions
diff --git a/src/main/java/at/gv/egiz/moazs/service/MsgService.java b/src/main/java/at/gv/egiz/moazs/service/MsgService.java
index 87644a0..9f94cb3 100644
--- a/src/main/java/at/gv/egiz/moazs/service/MsgService.java
+++ b/src/main/java/at/gv/egiz/moazs/service/MsgService.java
@@ -1,5 +1,4 @@
 package at.gv.egiz.moazs.service;
-import at.gv.egiz.moazs.process.MsgResponseHandler;
 import at.gv.egiz.moazs.repository.DeliveryRepository;
 import at.gv.egiz.moazs.scheme.MsgResponse;
 import at.gv.egiz.moazs.scheme.NameSpace;
@@ -10,6 +9,8 @@ import org.apache.cxf.annotations.SchemaValidation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.function.Consumer;
+
 import static at.gv.zustellung.msg.xsd.DeliveryNotificationACKType.deliveryNotificationACKTypeBuilder;
 import static at.gv.zustellung.msg.xsd.DeliveryRequestStatusACKType.deliveryRequestStatusACKTypeBuilder;
 import static at.gv.zustellung.msg.xsd.GetVersionResponse.getVersionResponseBuilder;
@@ -20,12 +21,12 @@ import static java.util.concurrent.CompletableFuture.runAsync;
 public class MsgService implements Zuse2AppPort {
 
     private final DeliveryRepository repository;
-    private final MsgResponseHandler handler;
+    private final Consumer<String> backend;
 
     @Autowired
-    public MsgService(DeliveryRepository repository, MsgResponseHandler handler) {
+    public MsgService(DeliveryRepository repository, Consumer<String> msgResponseBackend) {
         this.repository = repository;
-        this.handler = handler;
+        this.backend = msgResponseBackend;
     }
 
     @Override
@@ -59,7 +60,7 @@ public class MsgService implements Zuse2AppPort {
 
     private void sendToWork(MsgResponse response) {
         runAsync(() -> repository.store(response))
-            .thenRunAsync(() -> handler.handle(response.getResponseID()));
+            .thenRunAsync(() -> backend.accept(response.getResponseID()));
     }
 
     private DeliveryNotificationACKType notificationAck(String appDeliveryID, String zsDeliveryID) {