1 files changed, 14 insertions, 10 deletions

diff --git a/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/pipelines/CpeAuthenticationPipeline.java b/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/pipelines/CpeAuthenticationPipeline.java
index 711ab185..a30903bb 100644
--- a/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/pipelines/CpeAuthenticationPipeline.java
+++ b/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/pipelines/CpeAuthenticationPipeline.java
@@ -49,11 +49,11 @@ import org.onap.bbs.event.processor.model.ServiceInstanceAaiObject;
 import org.onap.bbs.event.processor.tasks.AaiClientTask;
 import org.onap.bbs.event.processor.tasks.DmaapCpeAuthenticationConsumerTask;
 import org.onap.bbs.event.processor.tasks.DmaapPublisherTask;
+import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpResponse;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.MDC;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
 
@@ -99,7 +99,7 @@ public class CpeAuthenticationPipeline {
         LOGGER.trace("Reactive CPE Authentication pipeline subscribed - Execution started");
     }
 
-    Flux<ResponseEntity<String>> executePipeline() {
+    Flux<HttpResponse> executePipeline() {
         return
             // Consume CPE Authentication from DMaaP
             consumeCpeAuthenticationFromDmaap()
@@ -111,11 +111,11 @@ public class CpeAuthenticationPipeline {
             .flatMap(this::triggerPolicy);
     }
 
-    private void onSuccess(ResponseEntity<String> responseCode) {
-        MDC.put(RESPONSE_CODE, responseCode.getStatusCode().toString());
+    private void onSuccess(HttpResponse responseCode) {
+        MDC.put(RESPONSE_CODE, String.valueOf(responseCode.statusCode()));
         LOGGER.info("CPE Authentication event successfully handled. "
                         + "Publishing to DMaaP for Policy returned a status code of ({} {})",
-                responseCode.getStatusCode().value(), responseCode.getStatusCode().getReasonPhrase());
+                responseCode.statusCode(), responseCode.statusReason());
         MDC.remove(RESPONSE_CODE);
     }
 
@@ -171,8 +171,10 @@ public class CpeAuthenticationPipeline {
                 .doOnError(TimeoutException.class,
                         e -> LOGGER.warn("Timed out waiting for A&AI response")
                 )
-                .doOnError(e -> LOGGER.error("Error while retrieving PNF: {}",
-                        e.getMessage())
+                .doOnError(e -> {
+                            LOGGER.error("Error while retrieving PNF: {}", e.getMessage());
+                            LOGGER.debug("Error\n", e);
+                        }
                 )
                 .onErrorResume(
                     e -> e instanceof Exception,
@@ -214,8 +216,10 @@ public class CpeAuthenticationPipeline {
                 .doOnError(TimeoutException.class,
                         e -> LOGGER.warn("Timed out waiting for A&AI response")
                 )
-                .doOnError(e -> LOGGER.error("Error while retrieving HSI CFS Service instance: {}",
-                        e.getMessage())
+                .doOnError(e -> {
+                            LOGGER.error("Error while retrieving HSI CFS Service instance: {}", e.getMessage());
+                            LOGGER.debug("Error\n", e);
+                        }
                 )
                 .onErrorResume(
                     e -> e instanceof Exception,
@@ -226,7 +230,7 @@ public class CpeAuthenticationPipeline {
                 });
     }
 
-    private Mono<ResponseEntity<String>> triggerPolicy(PipelineState state) {
+    private Mono<HttpResponse> triggerPolicy(PipelineState state) {
 
         if (state == null || state.getHsiCfsServiceInstance() == null) {
             return Mono.empty();