From cec614d561bcf9543c99bddd2b051b4a053dee0f Mon Sep 17 00:00:00 2001 From: PatrikBuhr Date: Mon, 11 May 2020 08:47:45 +0200 Subject: [PATCH] Handling Dmaap messages in a series To gurante that messges are handled in the right order they must be processed in a series instead of in paralell. Change-Id: I156bade6dc2d5100403681b452aadf473f6b94ed Issue-ID: NONRTRIC-210 Signed-off-by: PatrikBuhr --- .../java/org/oransc/policyagent/dmaap/DmaapMessageHandler.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageHandler.java b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageHandler.java index 3c44f085..8cfb55ba 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageHandler.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageHandler.java @@ -56,10 +56,12 @@ public class DmaapMessageHandler { } public void handleDmaapMsg(String msg) { - this.createTask(msg) // - .subscribe(message -> logger.debug("handleDmaapMsg: {}", message), // - throwable -> logger.warn("handleDmaapMsg failure {}", throwable.getMessage()), // - () -> logger.debug("handleDmaapMsg complete")); + try { + String result = this.createTask(msg).block(); + logger.debug("handleDmaapMsg: {}", result); + } catch (Exception throwable) { + logger.warn("handleDmaapMsg failure {}", throwable.getMessage()); + } } Mono createTask(String msg) { -- 2.16.6