From 7679a6f8177d47116aa8dbae0b38f8b0a8174dc5 Mon Sep 17 00:00:00 2001
From: wasala <przemyslaw.wasala@nokia.com>
Date: Tue, 7 Aug 2018 13:40:42 +0200
Subject: Fix corrections in code

*FindBugs scan fixed errors
*Checkstyle fixed errors

Change-Id: I8553a56859de91f8886fc1518ff26e7b16c5c1d6
Issue-ID: DCAEGEN2-606
Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
---
 .../prh/exceptions/AaiRequestException.java        |  3 ---
 .../services/prh/service/AaiReactiveWebClient.java |  2 +-
 .../producer/AaiProducerReactiveHttpClient.java    | 30 ++++++++++++----------
 3 files changed, 18 insertions(+), 17 deletions(-)

(limited to 'prh-aai-client/src/main/java/org')

diff --git a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/exceptions/AaiRequestException.java b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/exceptions/AaiRequestException.java
index 33654c73..bd4355cd 100644
--- a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/exceptions/AaiRequestException.java
+++ b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/exceptions/AaiRequestException.java
@@ -21,9 +21,6 @@
 package org.onap.dcaegen2.services.prh.exceptions;
 
 public class AaiRequestException extends Exception {
-    public AaiRequestException() {
-        super();
-    }
 
     public AaiRequestException(String message) {
         super(message);
diff --git a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AaiReactiveWebClient.java b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AaiReactiveWebClient.java
index f3b511a7..2b156936 100644
--- a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AaiReactiveWebClient.java
+++ b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/AaiReactiveWebClient.java
@@ -40,7 +40,7 @@ public class AaiReactiveWebClient {
     private Map<String, String> aaiHeaders;
 
     /**
-     * Creating AaiReactiveWebClient
+     * Creating AaiReactiveWebClient.
      * @param configuration - configuration object
      * @return AaiReactiveWebClient
      */
diff --git a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java
index 55475902..b43c2164 100644
--- a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java
+++ b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java
@@ -43,7 +43,7 @@ public class AaiProducerReactiveHttpClient {
 
 
     /**
-     * Constructor
+     * Constructor of AaiProducerReactiveHttpClient.
      *
      * @param configuration - AAI producer configuration object
      */
@@ -55,7 +55,7 @@ public class AaiProducerReactiveHttpClient {
     }
 
     /**
-     * Function for calling AAI Http producer - patch request to AAI database
+     * Function for calling AAI Http producer - patch request to AAI database.
      *
      * @param consumerDmaapModelMono - object which will be sent to AAI database
      * @return status code of operation
@@ -72,12 +72,16 @@ public class AaiProducerReactiveHttpClient {
     private Mono<Integer> patchAaiRequest(ConsumerDmaapModel dmaapModel) {
         try {
             return webClient.patch()
-                    .uri(getUri(dmaapModel.getPnfName()))
-                    .body(BodyInserters.fromObject(dmaapModel))
-                    .retrieve()
-                    .onStatus(HttpStatus::is4xxClientError, clientResponse -> Mono.error(new AaiRequestException("HTTP 400")))
-                    .onStatus(HttpStatus::is5xxServerError, clientResponse -> Mono.error(new AaiRequestException("HTTP 500")))
-                    .bodyToMono(Integer.class);
+                .uri(getUri(dmaapModel.getPnfName()))
+                .body(BodyInserters.fromObject(dmaapModel))
+                .retrieve()
+                .onStatus(
+                    HttpStatus::is4xxClientError,
+                    clientResponse -> Mono.error(new AaiRequestException("HTTP 400"))
+                )
+                .onStatus(HttpStatus::is5xxServerError,
+                    clientResponse -> Mono.error(new AaiRequestException("HTTP 500")))
+                .bodyToMono(Integer.class);
         } catch (URISyntaxException e) {
             return Mono.error(e);
         }
@@ -85,10 +89,10 @@ public class AaiProducerReactiveHttpClient {
 
     URI getUri(String pnfName) throws URISyntaxException {
         return new URIBuilder()
-                .setScheme(aaiProtocol)
-                .setHost(aaiHost)
-                .setPort(aaiHostPortNumber)
-                .setPath(aaiBasePath + "/" + pnfName)
-                .build();
+            .setScheme(aaiProtocol)
+            .setHost(aaiHost)
+            .setPort(aaiHostPortNumber)
+            .setPath(aaiBasePath + "/" + pnfName)
+            .build();
     }
 }
-- 
cgit 1.2.3-korg