Reactive A&AI client

*plugged reactiveHttpClient in
prh workflow
*added junit tests for workflow

Change-Id: I74f3fa7354de9b0f7f164c070ea61b70e74bde23
Issue-ID: DCAEGEN2-609
Signed-off-by: wasala <przemyslaw.wasala@nokia.com>

1 files changed, 5 insertions, 7 deletions

diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java
index 664eb33c..c021abe2 100644
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java
@@ -95,13 +95,11 @@ public class ScheduledTasks {
     }
 
     private Mono<ConsumerDmaapModel> publishToAaiConfiguration(Mono<ConsumerDmaapModel> monoDMaaPModel) {
-        return monoDMaaPModel.flatMap(dmaapModel -> {
-            try {
-                return Mono.just(aaiProducerTask.execute(dmaapModel));
-            } catch (PrhTaskException e) {
-                return Mono.error(e);
-            }
-        });
+        try {
+            return aaiProducerTask.execute(monoDMaaPModel);
+        } catch (PrhTaskException e) {
+            return Mono.error(e);
+        }
     }
 
     private Mono<String> publishToDmaapConfiguration(Mono<ConsumerDmaapModel> monoAaiModel) {