Disable DMaaP if Kafka active

DMaaP healthcheck cannot succeed when using Kafka, which in turn causes distribution to fail

Signed-off-by: Vasyl Razinkov <vasyl.razinkov@est.tech>
Change-Id: Ia6e1e35b9a2e819e38e62caeb797342948f34e92
Issue-ID: SDC-4542

1 files changed, 41 insertions, 344 deletions

diff --git a/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java b/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java
index 205588adab..72870ea1d9 100644
--- a/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java
+++ b/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java
@@ -19,14 +19,21 @@
  */
 package org.openecomp.sdc.be.config;
 
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+import org.openecomp.sdc.common.api.BasicConfiguration;
+import org.openecomp.sdc.common.http.config.ExternalServiceConfig;
+
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import org.openecomp.sdc.common.api.BasicConfiguration;
-import org.openecomp.sdc.common.http.config.ExternalServiceConfig;
 
+@Getter
+@Setter
 public class DistributionEngineConfiguration extends BasicConfiguration {
 
     private List<String> uebServers;
@@ -52,82 +59,6 @@ public class DistributionEngineConfiguration extends BasicConfiguration {
     private Integer opEnvRecoveryIntervalSec;
     private Integer allowedTimeBeforeStaleSec;
 
-    public List<String> getUebServers() {
-        return uebServers;
-    }
-
-    public void setUebServers(List<String> uebServers) {
-        this.uebServers = uebServers;
-    }
-
-    public String getDistributionNotifTopicName() {
-        return distributionNotifTopicName;
-    }
-
-    public void setDistributionNotifTopicName(String distributionNotifTopicName) {
-        this.distributionNotifTopicName = distributionNotifTopicName;
-    }
-
-    public String getDistributionStatusTopicName() {
-        return distributionStatusTopicName;
-    }
-
-    public void setDistributionStatusTopicName(String distributionStatusTopicName) {
-        this.distributionStatusTopicName = distributionStatusTopicName;
-    }
-
-    public String getKafkaBootStrapServers() {
-        return kafkaBootStrapServers;
-    }
-
-    public void setKafkaBootStrapServers(String kafkaBootStrapServers) {
-        this.kafkaBootStrapServers = kafkaBootStrapServers;
-    }
-
-    public Integer getInitRetryIntervalSec() {
-        return initRetryIntervalSec;
-    }
-
-    public void setInitRetryIntervalSec(Integer initRetryIntervalSec) {
-        this.initRetryIntervalSec = initRetryIntervalSec;
-    }
-
-    public ComponentArtifactTypesConfig getDistribNotifServiceArtifactTypes() {
-        return distribNotifServiceArtifactTypes;
-    }
-
-    public void setDistribNotifServiceArtifactTypes(ComponentArtifactTypesConfig distribNotifServiceArtifactTypes) {
-        this.distribNotifServiceArtifactTypes = distribNotifServiceArtifactTypes;
-    }
-
-    public ComponentArtifactTypesConfig getDistribNotifResourceArtifactTypes() {
-        return distribNotifResourceArtifactTypes;
-    }
-
-    public void setDistribNotifResourceArtifactTypes(ComponentArtifactTypesConfig distribNotifResourceArtifactTypes) {
-        this.distribNotifResourceArtifactTypes = distribNotifResourceArtifactTypes;
-    }
-
-    public String getUebPublicKey() {
-        return uebPublicKey;
-    }
-
-    public void setUebPublicKey(String uebPublicKey) {
-        this.uebPublicKey = uebPublicKey;
-    }
-
-    public String getUebSecretKey() {
-        return uebSecretKey;
-    }
-
-    public void setUebSecretKey(String uebSecretKey) {
-        this.uebSecretKey = uebSecretKey;
-    }
-
-    public List<String> getEnvironments() {
-        return environments;
-    }
-
     public void setEnvironments(List<String> environments) {
         Set<String> set = new HashSet<>();
         if (environments != null) {
@@ -138,218 +69,64 @@ public class DistributionEngineConfiguration extends BasicConfiguration {
         }
     }
 
-    public DistributionStatusTopicConfig getDistributionStatusTopic() {
-        return distributionStatusTopic;
-    }
-
-    public void setDistributionStatusTopic(DistributionStatusTopicConfig distributionStatusTopic) {
-        this.distributionStatusTopic = distributionStatusTopic;
-    }
-
-    public Integer getInitMaxIntervalSec() {
-        return initMaxIntervalSec;
-    }
-
-    public void setInitMaxIntervalSec(Integer initMaxIntervalSec) {
-        this.initMaxIntervalSec = initMaxIntervalSec;
-    }
-
-    public CreateTopicConfig getCreateTopic() {
-        return createTopic;
-    }
-
-    public void setCreateTopic(CreateTopicConfig createTopic) {
-        this.createTopic = createTopic;
-    }
-
-    public boolean isStartDistributionEngine() {
-        return startDistributionEngine;
-    }
-
-    public void setStartDistributionEngine(boolean startDistributionEngine) {
-        this.startDistributionEngine = startDistributionEngine;
-    }
-
-    public DistributionNotificationTopicConfig getDistributionNotificationTopic() {
-        return distributionNotificationTopic;
-    }
-
-    public void setDistributionNotificationTopic(DistributionNotificationTopicConfig distributionNotificationTopic) {
-        this.distributionNotificationTopic = distributionNotificationTopic;
-    }
-
-    public int getDefaultArtifactInstallationTimeout() {
-        return defaultArtifactInstallationTimeout;
-    }
-
-    public void setDefaultArtifactInstallationTimeout(int defaultArtifactInstallationTimeout) {
-        this.defaultArtifactInstallationTimeout = defaultArtifactInstallationTimeout;
-    }
-
-    public int getCurrentArtifactInstallationTimeout() {
-        return currentArtifactInstallationTimeout;
-    }
-
-    public void setCurrentArtifactInstallationTimeout(int currentArtifactInstallationTimeout) {
-        this.currentArtifactInstallationTimeout = currentArtifactInstallationTimeout;
-    }
-
-    public boolean isUseHttpsWithDmaap() {
-        return useHttpsWithDmaap;
-    }
-
-    public void setUseHttpsWithDmaap(boolean useHttpsWithDmaap) {
-        this.useHttpsWithDmaap = useHttpsWithDmaap;
-    }
-
-    public Integer getOpEnvRecoveryIntervalSec() {
-        return opEnvRecoveryIntervalSec;
-    }
-
-    public void setOpEnvRecoveryIntervalSec(Integer opEnvRecoveryIntervalSec) {
-        this.opEnvRecoveryIntervalSec = opEnvRecoveryIntervalSec;
-    }
-
-    public Integer getAllowedTimeBeforeStaleSec() {
-        return allowedTimeBeforeStaleSec;
-    }
-
-    public void setAllowedTimeBeforeStaleSec(Integer allowedTimeBeforeStaleSec) {
-        this.allowedTimeBeforeStaleSec = allowedTimeBeforeStaleSec;
-    }
-
-    public ExternalServiceConfig getAaiConfig() {
-        return aaiConfig;
-    }
-
-    public void setAaiConfig(ExternalServiceConfig aaiConfig) {
-        this.aaiConfig = aaiConfig;
-    }
-
-    public ExternalServiceConfig getMsoConfig() {
-        return msoConfig;
-    }
-
-    public void setMsoConfig(ExternalServiceConfig msoConfig) {
-        this.msoConfig = msoConfig;
-    }
-
+    @Getter
+    @AllArgsConstructor
     public enum ArtifcatTypeEnum {
-        MURANO_PKG("MURANO-PKG"), HEAT("HEAT"), DG_XML("DG_XML");
-        String value;
-
-        private ArtifcatTypeEnum(String value) {
-            this.value = value;
-        }
+        MURANO_PKG("MURANO-PKG"),
+        HEAT("HEAT"),
+        DG_XML("DG_XML");
+        private final String value;
 
-        public String getValue() {
-            return value;
-        }
     }
 
+    @Getter
+    @Setter
     public static class DistribNotifServiceArtifacts {
 
-        Map<String, Object> service;
-        Map<String, Object> resource;
+        private Map<String, Object> service;
+        private Map<String, Object> resource;
 
-        public Map<String, Object> getService() {
-            return service;
-        }
-
-        public void setService(Map<String, Object> service) {
-            this.service = service;
-        }
-
-        public Map<String, Object> getResource() {
-            return resource;
-        }
-
-        public void setResource(Map<String, Object> resource) {
-            this.resource = resource;
-        }
     }
 
+    @Getter
+    @Setter
     public static class NotifArtifactTypes {
 
-        List<String> info;
-        List<String> lifecycle;
-
-        public List<String> getInfo() {
-            return info;
-        }
-
-        public void setInfo(List<String> info) {
-            this.info = info;
-        }
-
-        public List<String> getLifecycle() {
-            return lifecycle;
-        }
+        private List<String> info;
+        private List<String> lifecycle;
 
-        public void setLifecycle(List<String> lifecycle) {
-            this.lifecycle = lifecycle;
-        }
     }
 
+    @Getter
+    @Setter
     public static class NotifArtifactTypesResource {
 
-        List<ArtifcatTypeEnum> lifecycle;
+        private List<ArtifcatTypeEnum> lifecycle;
     }
 
+    @Getter
+    @Setter
+    @ToString
     public static class CreateTopicConfig {
 
         private Integer partitionCount;
         private Integer replicationCount;
 
-        public Integer getPartitionCount() {
-            return partitionCount;
-        }
-
-        public void setPartitionCount(Integer partitionCount) {
-            this.partitionCount = partitionCount;
-        }
-
-        public Integer getReplicationCount() {
-            return replicationCount;
-        }
-
-        public void setReplicationCount(Integer replicationCount) {
-            this.replicationCount = replicationCount;
-        }
-
-        @Override
-        public String toString() {
-            return "CreateTopicConfig [partitionCount=" + partitionCount + ", replicationCount=" + replicationCount + "]";
-        }
     }
 
+    @Getter
+    @Setter
+    @ToString
     public static class EnvironmentConfig {
 
         private String name;
         private List<String> uebServers;
 
-        public String getName() {
-            return name;
-        }
-
-        public void setName(String name) {
-            this.name = name;
-        }
-
-        public List<String> getUebServers() {
-            return uebServers;
-        }
-
-        public void setUebServers(List<String> uebServers) {
-            this.uebServers = uebServers;
-        }
-
-        @Override
-        public String toString() {
-            return "EnvironmentConfig [name=" + name + ", uebServers=" + uebServers + "]";
-        }
     }
 
+    @Getter
+    @Setter
+    @ToString
     public static class DistributionStatusTopicConfig {
 
         private Integer pollingIntervalSec;
@@ -357,106 +134,26 @@ public class DistributionEngineConfiguration extends BasicConfiguration {
         private String consumerGroup;
         private String consumerId;
 
-        public Integer getPollingIntervalSec() {
-            return pollingIntervalSec;
-        }
-
-        public void setPollingIntervalSec(Integer pollingIntervalSec) {
-            this.pollingIntervalSec = pollingIntervalSec;
-        }
-
-        public Integer getFetchTimeSec() {
-            return fetchTimeSec;
-        }
-
-        public void setFetchTimeSec(Integer fetchTimeSec) {
-            this.fetchTimeSec = fetchTimeSec;
-        }
-
-        public String getConsumerGroup() {
-            return consumerGroup;
-        }
-
-        public void setConsumerGroup(String consumerGroup) {
-            this.consumerGroup = consumerGroup;
-        }
-
-        public String getConsumerId() {
-            return consumerId;
-        }
-
-        public void setConsumerId(String consumerId) {
-            this.consumerId = consumerId;
-        }
-
-        @Override
-        public String toString() {
-            return "DistributionStatusTopicConfig [pollingIntervalSec=" + pollingIntervalSec + ", fetchTimeSec=" + fetchTimeSec + ", consumerGroup="
-                + consumerGroup + ", consumerId=" + consumerId + "]";
-        }
     }
 
+    @Getter
+    @Setter
+    @ToString
     public static class DistributionNotificationTopicConfig {
 
         private Integer maxWaitingAfterSendingSeconds;
         private Integer maxThreadPoolSize;
         private Integer minThreadPoolSize;
 
-        public Integer getMaxWaitingAfterSendingSeconds() {
-            return maxWaitingAfterSendingSeconds;
-        }
-
-        public void setMaxWaitingAfterSendingSeconds(Integer maxWaitingAfterSendingSeconds) {
-            this.maxWaitingAfterSendingSeconds = maxWaitingAfterSendingSeconds;
-        }
-
-        public Integer getMaxThreadPoolSize() {
-            return maxThreadPoolSize;
-        }
-
-        public void setMaxThreadPoolSize(Integer maxThreadPoolSize) {
-            this.maxThreadPoolSize = maxThreadPoolSize;
-        }
-
-        public Integer getMinThreadPoolSize() {
-            return minThreadPoolSize;
-        }
-
-        public void setMinThreadPoolSize(Integer minThreadPoolSize) {
-            this.minThreadPoolSize = minThreadPoolSize;
-        }
-
-        @Override
-        public String toString() {
-            return "DistributionNotificationTopicConfig [maxWaitingAfterSendingSeconds=" + maxWaitingAfterSendingSeconds + ", maxThreadPoolSize="
-                + maxThreadPoolSize + ", minThreadPoolSize=" + minThreadPoolSize + "]";
-        }
     }
 
+    @Getter
+    @Setter
+    @ToString
     public static class ComponentArtifactTypesConfig {
 
         private List<String> info;
         private List<String> lifecycle;
 
-        public List<String> getInfo() {
-            return info;
-        }
-
-        public void setInfo(List<String> info) {
-            this.info = info;
-        }
-
-        public List<String> getLifecycle() {
-            return lifecycle;
-        }
-
-        public void setLifecycle(List<String> lifecycle) {
-            this.lifecycle = lifecycle;
-        }
-
-        @Override
-        public String toString() {
-            return "ArtifactTypesConfig [info=" + info + ", lifecycle=" + lifecycle + "]";
-        }
     }
 }