diff options
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.java | 20 |
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; } |