diff options
author | Christof Rabensteiner <christof.rabensteiner@iaik.tugraz.at> | 2019-12-06 13:18:12 +0100 |
---|---|---|
committer | Christof Rabensteiner <christof.rabensteiner@iaik.tugraz.at> | 2019-12-06 13:18:12 +0100 |
commit | ff1e38bfa954dd747a5ff185dfe51c120d5ab5e7 (patch) | |
tree | 98b270471b8170b666421f90d9a93228717c9bbe /src/main/java/at/gv/egiz/moazs/service/MzsService.java | |
parent | 6b2201998fd4c2404e52c63b40b3f60c2dc126d1 (diff) | |
download | moa-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.java | 3 |
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); } |