Check Db enabled flag

[dcaegen2/services.git] / components / datalake-handler / feeder / src / main / java / org / onap / datalake / feeder / domain / Topic.java

diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Topic.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Topic.java
index acb48ae..c171c56 100644 (file)
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Topic.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Topic.java
@@ -161,14 +161,20 @@ public class Topic {
                tConfig.setAggregateArrayPath(getAggregateArrayPath());
                tConfig.setFlattenArrayPath(getFlattenArrayPath());
                tConfig.setTtl(getTtl());
+               
                Set<Db> topicDb = getDbs();
                List<String> dbList = new ArrayList<>();
+               List<String> enabledDbList = new ArrayList<>();
                if (topicDb != null) {
                        for (Db item : topicDb) {
                                dbList.add(item.getName());
+                               if(item.isEnabled()) {
+                                       enabledDbList.add(item.getName());
+                               }
                        }
                }
                tConfig.setSinkdbs(dbList);
+               tConfig.setEnabledSinkdbs(enabledDbList);
 
                return tConfig;
        }