summaryrefslogtreecommitdiffstats
path: root/policy-management/src/main/java
diff options
context:
space:
mode:
authorLiam Fallon <liam.fallon@est.tech>2023-12-19 11:42:32 +0000
committerGerrit Code Review <gerrit@onap.org>2023-12-19 11:42:32 +0000
commit36d9699056890640daeaa2fef2f2e4d469b433cb (patch)
treeddd5efa13d511e02318db23baa397f67a727cad1 /policy-management/src/main/java
parent5150ed1374d3393ac412ef6cd8e045e7e1514a5a (diff)
parentfbf94a6505d7c4b7c009446ca7dca93a9ce0db4d (diff)
Merge "Add kafka support on drools-pdp"
Diffstat (limited to 'policy-management/src/main/java')
-rw-r--r--policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java6
-rw-r--r--policy-management/src/main/java/org/onap/policy/drools/server/restful/RestManager.java6
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");