diff options
Diffstat (limited to 'src/main/java/org/onap/pomba/contextaggregator/service')
-rw-r--r-- | src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java b/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java index f79bf96..9e9f129 100644 --- a/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java +++ b/src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java @@ -70,7 +70,7 @@ public class ContextAggregatorProcessor implements Callable<Void> { @Autowired private MRTopicManager messageRouterTopicMgr; - @Autowired + @Value("${transport.message-router.requiredPombaTopics}") private String messageRouterRequiredPombaTopicList; @Autowired @@ -122,6 +122,14 @@ public class ContextAggregatorProcessor implements Callable<Void> { } } + /** + * The configurable POMBA Topics (POA-AUDIT-INIT,POA-AUDIT-RESULT,POA-RULE-VALIDATION, etc.) + * will be created if any of topics doesn't exist prior to be invoked. + * + * @param eventPayload + * @return + * @throws ContextAggregatorException + */ @Override public Void call() throws Exception { createPombaTopics(); |