summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGurjeet Bedi <gurjeetb@amdocs.com>2018-06-15 13:44:08 -0400
committerGurjeet Bedi <gurjeetb@amdocs.com>2018-06-15 13:45:01 -0400
commite80ce27a8d88a3fe91e1bada391a64ec9c20f1a6 (patch)
tree8283ba9cb6c2c61bec001bc6755623b315abc3ba
parent10b37f1a70a1b366fc8a537f62ac1417cc745847 (diff)
Inject event lib impl from data router
Event client impl through data router Issue-ID: AAI-1228 Change-Id: Ie934278fb0360689d1d7e36ee267fc988ce03919 Signed-off-by: Gurjeet Bedi <gurjeetb@amdocs.com>
-rwxr-xr-xdata-router/dynamic/conf/entity-event-policy.xml9
-rwxr-xr-xdata-router/dynamic/routes/entity-event.route2
2 files changed, 10 insertions, 1 deletions
diff --git a/data-router/dynamic/conf/entity-event-policy.xml b/data-router/dynamic/conf/entity-event-policy.xml
index 37bc21a..ccd6648 100755
--- a/data-router/dynamic/conf/entity-event-policy.xml
+++ b/data-router/dynamic/conf/entity-event-policy.xml
@@ -21,4 +21,13 @@
<bean id="entityEventPolicy" class="org.onap.aai.datarouter.policy.EntityEventPolicy" init-method="startup" >
<constructor-arg ref="eepConfig"/>
</bean>
+
+ <bean id="consumerBean" class="org.onap.aai.event.client.DMaaPEventConsumer" >
+ <constructor-arg name="host" value="mr.api.simpledemo.openecomp.org:3904" />
+ <constructor-arg name="topic" value="AAI-EVENT" />
+ <constructor-arg name="username" value="test" />
+ <constructor-arg name="password" value="test" />
+ <constructor-arg name="consumerGroup" value="datarouter" />
+ <constructor-arg name="consumerId" value="datarouter" />
+ </bean>
</beans>
diff --git a/data-router/dynamic/routes/entity-event.route b/data-router/dynamic/routes/entity-event.route
index 7d2de39..a7b38e3 100755
--- a/data-router/dynamic/routes/entity-event.route
+++ b/data-router/dynamic/routes/entity-event.route
@@ -1,4 +1,4 @@
<route xmlns="http://camel.apache.org/schema/spring" trace="true">
- <from uri="event-bus:mybus/?eventTopic=AAI-EVENT&amp;groupName=datarouter&amp;groupId=datarouter&amp;url=http://mr.api.simpledemo.openecomp.org:3904"/>
+ <from uri="event-bus:mybus/?eventTopic=AAI-EVENT&amp;consumer=#consumerBean"/>
<to uri="bean:entityEventPolicy?method=process"/>
</route>