From ff1e38bfa954dd747a5ff185dfe51c120d5ab5e7 Mon Sep 17 00:00:00 2001 From: Christof Rabensteiner Date: Fri, 6 Dec 2019 13:18:12 +0100 Subject: Change msg service: Acknowledge Response iff Backend Succeeds - Before: Upon receipt of a message via the msg/ endpoint, MOA ZS would immediately acknowledge the receipt without verifying that the message was successfully processed by the backend. - Now: MOA ZS receives a message via the msg/ endpoint, forwards it to the sinks, and acknowledges the receipt if and only if the processing succeeded. --- src/main/java/at/gv/egiz/moazs/service/MzsService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/main/java/at/gv/egiz/moazs/service/MzsService.java') 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 ee14af8..caaa251 100644 --- a/src/main/java/at/gv/egiz/moazs/service/MzsService.java +++ b/src/main/java/at/gv/egiz/moazs/service/MzsService.java @@ -142,7 +142,8 @@ public class MzsService implements App2MzsPortType { log.info(SERVICE_TIME_OUT_REACHED_MSG, appDeliveryID); var sinkParams = request.getConfig().getMsgResponseSinks(); - requestProcessed.thenAcceptAsync(response -> hub.applySinks(response, sinkParams), taskExecutor); + + requestProcessed.thenCompose(response -> hub.applySinks(response, sinkParams)); return generatePartialSuccessResponse(appDeliveryID); } -- cgit v1.2.3