diff options
| author |   Pamela Dragosh <pdragosh@research.att.com> | 2019-03-20 13:45:30 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2019-03-20 13:45:30 +0000 |
| commit | 232bd030951905cb5ad2f1ddad5400a005fe40c6 (patch) | |
| tree | 240eebda61412744b9346c6b44bc2c36a7757290 /policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java | |
| parent | 8fa0f6670063657249f75d9656d61fed5bf0b79f (diff) | |
| parent | cc4765116c0b5716f8edf4dc23970e964bb1fe5d (diff) | |
Merge "Add method to support configure all topics at once"
Diffstat (limited to 'policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java')
| -rw-r--r-- | policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java index ebed381d..806d077c 100644 --- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java +++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java @@ -56,6 +56,13 @@ class TopicEndpointProxy implements TopicEndpoint { private volatile boolean alive = false; @Override + public List<Topic> addTopics(Properties properties) { + List<Topic> topics = new ArrayList<>(addTopicSources(properties)); + topics.addAll(addTopicSinks(properties)); + return topics; + } + + @Override public List<TopicSource> addTopicSources(Properties properties) { // 1. Create UEB Sources |