1 files changed, 7 insertions, 3 deletions

diff --git a/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java b/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java
index 0da9c92..81398da 100644
--- a/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java
+++ b/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java
@@ -31,6 +31,7 @@ import at.gv.zustellung.app2mzs.xsd.DeliveryRequestType;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.task.TaskExecutor;
 import org.springframework.stereotype.Component;
 
 import java.util.Map;
@@ -64,18 +65,21 @@ public class MsgResponseBackend implements Consumer<String> {
     private final MsgResponseSinkHub hub;
     private final Map<String, ConfigType> deliveryRequestConfigs;
     private final MzsDeliveryRequestValidator validator;
+    private final TaskExecutor taskExecutor;
 
     @Autowired
     public MsgResponseBackend(DeliveryRepository repository,
                               Consumer<byte[]> signatureVerifier,
                               MsgResponseSinkHub hub,
                               Map<String, ConfigType> deliveryRequestConfigs,
-                              MzsDeliveryRequestValidator validator) {
+                              MzsDeliveryRequestValidator validator,
+                              TaskExecutor taskExecutor) {
         this.repository = repository;
         this.signatureVerifier = signatureVerifier;
         this.hub = hub;
         this.deliveryRequestConfigs = deliveryRequestConfigs;
         this.validator = validator;
+        this.taskExecutor = taskExecutor;
     }
 
     /**
@@ -91,8 +95,8 @@ public class MsgResponseBackend implements Consumer<String> {
     @Override
     public void accept(String responseID) {
         log.info("Backend accepts MsgResponse with responseID={}.", responseID);
-        supplyAsync(() -> verifySignature(responseID))
-                .thenAcceptAsync(msgResponse -> applySinks(msgResponse))
+        supplyAsync(() -> verifySignature(responseID), taskExecutor)
+                .thenAcceptAsync(msgResponse -> applySinks(msgResponse), taskExecutor)
                 .exceptionally(ex -> {
                     log.error(ex.getMessage(), ex);
                     return null;