diff options
Diffstat (limited to 'policy-management/src/main/java/org/onap/policy/drools/server/restful/RestManager.java')
| -rw-r--r-- | policy-management/src/main/java/org/onap/policy/drools/server/restful/RestManager.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/policy-management/src/main/java/org/onap/policy/drools/server/restful/RestManager.java b/policy-management/src/main/java/org/onap/policy/drools/server/restful/RestManager.java index b5cf319e..ad23ff3a 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/server/restful/RestManager.java +++ b/policy-management/src/main/java/org/onap/policy/drools/server/restful/RestManager.java @@ -1414,6 +1414,9 @@ public class RestManager implements SwaggerApi, DefaultApi, FeaturesApi, InputsA case NOOP: sources.addAll(TopicEndpointManager.getManager().getNoopTopicSources()); break; + case KAFKA: + sources.addAll(TopicEndpointManager.getManager().getKafkaTopicSources()); + break; default: status = Status.BAD_REQUEST; logger.debug("Invalid communication mechanism"); @@ -1449,6 +1452,9 @@ public class RestManager implements SwaggerApi, DefaultApi, FeaturesApi, InputsA case NOOP: sinks.addAll(TopicEndpointManager.getManager().getNoopTopicSinks()); break; + case KAFKA: + sinks.addAll(TopicEndpointManager.getManager().getKafkaTopicSinks()); + break; default: status = Status.BAD_REQUEST; logger.debug("Invalid communication mechanism"); |