diff options
| author |   Liam Fallon <liam.fallon@est.tech> | 2023-12-19 11:42:32 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2023-12-19 11:42:32 +0000 |
| commit | 36d9699056890640daeaa2fef2f2e4d469b433cb (patch) | |
| tree | ddd5efa13d511e02318db23baa397f67a727cad1 /policy-management/src | |
| parent | 5150ed1374d3393ac412ef6cd8e045e7e1514a5a (diff) | |
| parent | fbf94a6505d7c4b7c009446ca7dca93a9ce0db4d (diff) | |
Merge "Add kafka support on drools-pdp"
Diffstat (limited to 'policy-management/src')
2 files changed, 12 insertions, 0 deletions
diff --git a/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java b/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java index 5491eac7..0c732246 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java +++ b/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java @@ -271,6 +271,12 @@ class IndexedDroolsControllerFactory implements DroolsControllerFactory { } else { return PolicyEndPointProperties.PROPERTY_NOOP_SINK_TOPICS + "."; } + } else if (commInfra == CommInfrastructure.KAFKA) { + if (isSource) { + return PolicyEndPointProperties.PROPERTY_KAFKA_SOURCE_TOPICS + "."; + } else { + return PolicyEndPointProperties.PROPERTY_KAFKA_SINK_TOPICS + "."; + } } else { throw new IllegalArgumentException("Invalid Communication Infrastructure: " + commInfra); } 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"); |