aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/at/gv/egiz/moazs/service/MzsService.java
diff options
context:
space:
mode:
authorChristof Rabensteiner <christof.rabensteiner@iaik.tugraz.at>2019-12-06 13:18:12 +0100
committerChristof Rabensteiner <christof.rabensteiner@iaik.tugraz.at>2019-12-06 13:18:12 +0100
commitff1e38bfa954dd747a5ff185dfe51c120d5ab5e7 (patch)
tree98b270471b8170b666421f90d9a93228717c9bbe /src/main/java/at/gv/egiz/moazs/service/MzsService.java
parent6b2201998fd4c2404e52c63b40b3f60c2dc126d1 (diff)
downloadmoa-zs-ff1e38bfa954dd747a5ff185dfe51c120d5ab5e7.tar.gz
moa-zs-ff1e38bfa954dd747a5ff185dfe51c120d5ab5e7.tar.bz2
moa-zs-ff1e38bfa954dd747a5ff185dfe51c120d5ab5e7.zip
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.
Diffstat (limited to 'src/main/java/at/gv/egiz/moazs/service/MzsService.java')
-rw-r--r--src/main/java/at/gv/egiz/moazs/service/MzsService.java3
1 files changed, 2 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 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);
}