Refatoring due to prh workflow

1. Added specified HttpClient for DmaaPPublisher:
*DmaaP Handle transfer-encoding: chunk header and
reject the request if it will be set by the client.
In conclusion no other reactive http client can be
used for pushing something to dmaap.

2. Added sll support to A&AI rective webclient.
*Behaviour of reactive A&AI HttpClient is different as
in native spring have without it.

3. Added 10s fixed time in PRH for requesting DmaaP.

4. Added debug log in reactive/native http clients.

5. Fixed reactive workflow of prh.

6. Updated the version of:
* spring-boot-dependencies:2.0.1.RELEASE->2.0.4.RELEASE
* spring-boot-starter-reactor-netty:2.0.2.RELEASE->2.0.4.RELEASE
* spring-webflux:5.0.5.RELEASE->5.0.8.RELEASE
* reactor-bom:Bismuth-RELEASE->Bismuth-SR10

Change-Id: I815ffb5bdcf48d94f3b7c64040a73e98e404a5e8
Issue-ID: DCAEGEN2-743
Signed-off-by: pwielebs <piotr.wielebski@nokia.com>

1 files changed, 6 insertions, 6 deletions

diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/PrhConfigurationProvider.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/PrhConfigurationProvider.java
index 7af4a7c8..b346bf5e 100644
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/PrhConfigurationProvider.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/PrhConfigurationProvider.java
@@ -38,7 +38,7 @@ import java.net.URISyntaxException;
 @Service
 public class PrhConfigurationProvider {
 
-    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+    private static final Logger LOGGER = LoggerFactory.getLogger(PrhConfigurationProvider.class);
 
     private final HttpGetClient httpGetClient;
 
@@ -56,12 +56,12 @@ public class PrhConfigurationProvider {
     }
 
     private Mono<String> callConsulForConfigBindingServiceEndpoint(EnvProperties envProperties) {
-        logger.info("Retrieving Config Binding Service endpoint from Consul");
+        LOGGER.info("Retrieving Config Binding Service endpoint from Consul");
         try {
             return httpGetClient.callHttpGet(getConsulUrl(envProperties), JsonArray.class)
                 .flatMap(jsonArray -> this.createConfigBindingServiceURL(jsonArray, envProperties.appName()));
         } catch (URISyntaxException e) {
-            logger.warn("Malformed Consul uri", e);
+            LOGGER.warn("Malformed Consul uri", e);
             return Mono.error(e);
         }
     }
@@ -72,7 +72,7 @@ public class PrhConfigurationProvider {
     }
 
     private Mono<JsonObject> callConfigBindingServiceForPrhConfiguration(String configBindingServiceUri) {
-        logger.info("Retrieving PRH configuration");
+        LOGGER.info("Retrieving PRH configuration");
         return httpGetClient.callHttpGet(configBindingServiceUri, JsonObject.class);
     }
 
@@ -86,7 +86,7 @@ public class PrhConfigurationProvider {
             return Mono.just(getUri(jsonObject.get("ServiceAddress").getAsString(),
                 jsonObject.get("ServicePort").getAsInt(), "/service_component", appName));
         } catch (URISyntaxException e) {
-            logger.warn("Malformed Config Binding Service uri", e);
+            LOGGER.warn("Malformed Config Binding Service uri", e);
             return Mono.error(e);
         }
     }
@@ -99,7 +99,7 @@ public class PrhConfigurationProvider {
                 throw new IllegalStateException("JSON Array was empty");
             }
         } catch (IllegalStateException e) {
-            logger.warn("Failed to retrieve JSON Object from array", e);
+            LOGGER.warn("Failed to retrieve JSON Object from array", e);
             return Mono.error(e);
         }
     }