diff options
Diffstat (limited to 'policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java')
-rw-r--r-- | policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java | 6 |
1 files changed, 6 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); } |