From fb2eb3e99edfc76cbcda61c602a4734b6f21138c Mon Sep 17 00:00:00 2001
From: Venkata Harish K Kajur <vk250x@att.com>
Date: Mon, 5 Jun 2017 23:47:50 -0400
Subject: [AAI-ONAP] Make necessary changes to enable dmaap

Change-Id: Iba41aca29f59dce1c937e9a916f39b69521cdfe4
Signed-off-by: Venkata Harish K Kajur <vk250x@att.com>
---
 .../ajsc-aai_v1/ajsc-aai/v1/conf/serviceBeans.xml  | 55 +++++++++++++++++++++-
 1 file changed, 53 insertions(+), 2 deletions(-)

(limited to 'aai-traversal/src/main/ajsc/ajsc-aai_v1/ajsc-aai')

diff --git a/aai-traversal/src/main/ajsc/ajsc-aai_v1/ajsc-aai/v1/conf/serviceBeans.xml b/aai-traversal/src/main/ajsc/ajsc-aai_v1/ajsc-aai/v1/conf/serviceBeans.xml
index f4bc26a..2b90c85 100644
--- a/aai-traversal/src/main/ajsc/ajsc-aai_v1/ajsc-aai/v1/conf/serviceBeans.xml
+++ b/aai-traversal/src/main/ajsc/ajsc-aai_v1/ajsc-aai/v1/conf/serviceBeans.xml
@@ -34,6 +34,7 @@
 		</cxf:outInterceptors>
 	</cxf:bus>
 	<context:component-scan base-package="org.openecomp.aai.tasks" />
+	<context:component-scan base-package="org.openecomp.aai.config" />
 
 	<task:scheduler id="taskScheduler" pool-size="10" />
 	<task:executor id="taskExecutor" pool-size="10"
@@ -41,7 +42,57 @@
 	<task:annotation-driven executor="taskExecutor"
 		scheduler="taskScheduler" />
 
+	<bean id="jmsProperties"
+		  class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"
+		  name="jmsProperties">
+		<property name="order" value="99999" />
+		<property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
+		<property name="ignoreUnresolvablePlaceholders" value="true" />
+		<property name="properties">
+			<value>
 
-	
+				<!-- JMS -->
+				JMS.BROKER.URL=tcp://localhost:61446
+				JMS.QUEUE.NAME=IN_QUEUE
 
-</beans>		
\ No newline at end of file
+			</value>
+		</property>
+	</bean>
+
+	<!-- ActiveMQ connection factory -->
+	<bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
+		<constructor-arg index="0" value="${JMS.BROKER.URL}" />
+	</bean>
+
+	<!-- ConnectionFactory Definition -->
+	<bean id="connectionFactory"
+		  class="org.springframework.jms.connection.CachingConnectionFactory">
+		<constructor-arg ref="amqConnectionFactory" />
+	</bean>
+
+	<!-- Destination Queue -->
+	<bean id="destinationQueue" class="org.apache.activemq.command.ActiveMQQueue">
+		<constructor-arg index="0" value="${JMS.QUEUE.NAME}" />
+	</bean>
+
+	<!-- JmsTemplate Definition -->
+	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
+		<property name="connectionFactory" ref="connectionFactory" />
+		<property name="defaultDestination" ref="destinationQueue" />
+	</bean>
+
+	<!-- Message Producer -->
+	<bean id="messageProducer" class="org.openecomp.aai.dmaap.AAIDmaapEventJMSProducer" />
+
+	<!-- Message Consumer from Default Destination -->
+	<bean id="messageDefaultConsumer" class="org.openecomp.aai.dmaap.AAIDmaapEventJMSConsumer" />
+
+	<!-- Message Consumer Container for Default Destination -->
+	<bean
+			class="org.springframework.jms.listener.DefaultMessageListenerContainer">
+		<property name="connectionFactory" ref="connectionFactory" />
+		<property name="destinationName" value="${JMS.QUEUE.NAME}" />
+		<property name="messageListener" ref="messageDefaultConsumer" />
+	</bean>
+
+</beans>
\ No newline at end of file
-- 
cgit 1.2.3-korg