diff options
Diffstat (limited to 'src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java')
-rw-r--r-- | src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java | 10 |
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; |