From 46ccb96229c938c2f21114cb4f1e13aea188a350 Mon Sep 17 00:00:00 2001 From: vasraz Date: Thu, 11 Nov 2021 13:56:50 +0000 Subject: Fix auth failure to dmaap after upgrade Signed-off-by: MichaelMorris Issue-ID: SDC-3756 Change-Id: I58e6f99156e1e64443cd79c2e08f73987329b88d (cherry picked from commit 9e81c0f8d1c759cfe54312fed69b9ba263f4e52e) Signed-off-by: Vasyl Razinkov --- .../distribution/engine/DistributionEngineInitTask.java | 8 ++++++++ 1 file changed, 8 insertions(+) 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 6207cd2a5a..d61e15016a 100644 --- 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; -- cgit 1.2.3-korg