1 files changed, 5 insertions, 1 deletions
diff --git a/src/main/java/at/gv/egiz/moazs/service/MzsService.java b/src/main/java/at/gv/egiz/moazs/service/MzsService.java
index d9c81f3..55f0554 100644
--- a/src/main/java/at/gv/egiz/moazs/service/MzsService.java
+++ b/src/main/java/at/gv/egiz/moazs/service/MzsService.java
@@ -34,6 +34,7 @@ import org.apache.cxf.annotations.SchemaValidation;
 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.Service;
 
 import javax.jws.WebParam;
@@ -72,6 +73,9 @@ public class MzsService implements App2MzsPortType {
     private final MzsDeliveryRequestValidator validator;
 
     @Autowired
+    private TaskExecutor taskExecutor;
+
+    @Autowired
     public MzsService(DeliveryRepository repository, Consumer<String> deliveryRequestBackend,
                       DeliveryRequestAugmenter augmenter, Msg2MzsConverter converter,
                       MsgResponseSinkHub hub, MzsDeliveryRequestValidator validator) {
@@ -93,7 +97,7 @@ public class MzsService implements App2MzsPortType {
 
         validator.isRequestValid(completeRequest);
 
-        var requestProcessed = supplyAsync(() -> process(completeRequest));
+        var requestProcessed = supplyAsync(() -> process(completeRequest), taskExecutor);
 
         try {
             var serviceTimeout = completeRequest.getConfig().getServiceTimeout();