summaryrefslogtreecommitdiffstats
path: root/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java
diff options
context:
space:
mode:
Diffstat (limited to 'components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java')
-rw-r--r--components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java20
1 files changed, 16 insertions, 4 deletions
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java
index b59b2a7b..2500075b 100644
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java
@@ -93,16 +93,28 @@ public class TopicController {
return dmaapService.getTopics();
}
+ @GetMapping("/default")
+ @ResponseBody
+ @ApiOperation(value = "Get default topic configuration.")
+ public TopicConfig getDefaultConfig(HttpServletResponse response) throws IOException {
+ Topic topic = topicService.getDefaultTopicFromFeeder();
+ if(topic == null) {
+ sendError(response, 404, "Topic not found");
+ return null;
+ }
+ return topic.getTopicConfig();
+ }
+
@GetMapping("")
@ResponseBody
- @ApiOperation(value="List all topic names in database")
- public List<String> list() {
+ @ApiOperation(value="List all topic id in database")
+ public List<Integer> list() {
Iterable<Topic> ret = topicRepository.findAll();
- List<String> retString = new ArrayList<>();
+ List<Integer> retString = new ArrayList<>();
for(Topic item : ret)
{
if(!topicService.isDefaultTopic(item))
- retString.add(item.getName());
+ retString.add(item.getId());
}
return retString;
}