aboutsummaryrefslogtreecommitdiffstats
path: root/catalog-be/src
diff options
context:
space:
mode:
authorvasraz <vasyl.razinkov@est.tech>2021-11-11 13:56:50 +0000
committerMichael Morris <michael.morris@est.tech>2021-11-11 15:30:37 +0000
commit46ccb96229c938c2f21114cb4f1e13aea188a350 (patch)
treed830d0e52bc0dc496b2b26f7e63632a5b9c0e339 /catalog-be/src
parent44481e7703f91609f5e64cd39a105748dde35657 (diff)
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>
Diffstat (limited to 'catalog-be/src')
-rw-r--r--catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEngineInitTask.java8
1 files changed, 8 insertions, 0 deletions
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;