Fix auth failure to dmaap after upgrade

Signed-off-by: MichaelMorris <michael.morris@est.tech>
Issue-ID: SDC-3756
Change-Id: I58e6f99156e1e64443cd79c2e08f73987329b88d
(cherry picked from commit 9e81c0f8d1c759cfe54312fed69b9ba263f4e52e)
Signed-off-by: Vasyl Razinkov <vasyl.razinkov@est.tech>

diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEngineInitTask.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEngineInitTask.java
index 6207cd2..d61e150 100644 (file)
--- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEngineInitTask.java
+++ b/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEngineInitTask.java
@@ -197,6 +197,14 @@ public class DistributionEngineInitTask implements Runnable {
         CambriaErrorResponse registerStatus = cambriaHandler
             .registerToTopic(environmentEntry.getDmaapUebAddress(), environmentEntry.getUebApikey(), environmentEntry.getUebSecretKey(),
                 environmentEntry.getUebApikey(), subscriberType, topicName);
+
+        if (CambriaOperationStatus.AUTHENTICATION_ERROR.equals(registerStatus.getOperationStatus())
+                || CambriaOperationStatus.CONNNECTION_ERROR.equals(registerStatus.getOperationStatus())){
+            registerStatus = cambriaHandler
+                    .registerToTopic(environmentEntry.getDmaapUebAddress(), deConfiguration.getUebPublicKey(), deConfiguration.getUebSecretKey(),
+                            environmentEntry.getUebApikey(), subscriberType, topicName);
+        }
+
         String role = CONSUMER;
         if (subscriberType == SubscriberTypeEnum.PRODUCER) {
             role = PRODUCER;