summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorPhillip Leigh <phillip.leigh@amdocs.com>2018-11-23 15:38:00 -0500
committerLeigh, Phillip (pl876u) <phillip.leigh@amdocs.com>2018-11-26 14:05:03 -0500
commit011ac9cfcfd1d5aba077feffb0edbb25818e4ea0 (patch)
treeeb9458388443618d01ad7f9207a5e14912194ac8 /src
parenta74c306af14723da1f8a24bea5e3a8016dc449e0 (diff)
Pre-create POMBA Topics before calling in CtxAggr
Removing POMBA-TEST-ONLY topic and apply review comments. Issue-ID: LOG-824 Change-Id: I8cf293ca0edebad216decf5ace4f7911e7fcca86 Signed-off-by: Leigh, Phillip (pl876u) <phillip.leigh@amdocs.com>
Diffstat (limited to 'src')
-rw-r--r--src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java4
-rw-r--r--src/main/java/org/onap/pomba/contextaggregator/service/ContextAggregatorProcessor.java10
2 files changed, 9 insertions, 5 deletions
diff --git a/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java b/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java
index 1532f43..c030306 100644
--- a/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java
+++ b/src/main/java/org/onap/pomba/contextaggregator/config/TransportConfig.java
@@ -68,10 +68,6 @@ public class TransportConfig {
return mgr;
}
- @Bean
- public String messageRouterRequiredPombaTopicList(@Value("${transport.message-router.requiredPombaTopics}") String requiredPombaTopics) {
- return requiredPombaTopics;
- }
@Bean
public EventPublisherFactory publisherFactory(@Value("${transport.publish.host}") String host,
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();