--- /dev/null
+/*\r
+ * ============LICENSE_START========================================================================\r
+ * ONAP : tr-069-adapter\r
+ * =================================================================================================\r
+ * Copyright (C) 2020 CommScope Inc Intellectual Property.\r
+ * =================================================================================================\r
+ * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License,\r
+ * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You\r
+ * may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,\r
+ * either express or implied. See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ * ===============LICENSE_END=======================================================================\r
+ */\r
+\r
+package org.commscope.tr069adapter.acs.booter;\r
+\r
+import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.CR_REQ_Q;\r
+import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_NOTIFICATION_Q;\r
+import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_OP_RESULT_Q;\r
+import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.TR069_NBI_REQUEST_Q;\r
+\r
+import java.util.Arrays;\r
+\r
+import javax.jms.ConnectionFactory;\r
+\r
+import org.apache.activemq.ActiveMQConnectionFactory;\r
+import org.apache.activemq.RedeliveryPolicy;\r
+import org.apache.activemq.broker.BrokerService;\r
+import org.apache.activemq.broker.region.policy.RedeliveryPolicyMap;\r
+import org.apache.activemq.command.ActiveMQQueue;\r
+import org.apache.catalina.connector.Connector;\r
+import org.springframework.beans.factory.annotation.Value;\r
+import org.springframework.boot.SpringApplication;\r
+import org.springframework.boot.autoconfigure.SpringBootApplication;\r
+import org.springframework.boot.autoconfigure.domain.EntityScan;\r
+import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;\r
+import org.springframework.boot.web.client.RestTemplateBuilder;\r
+import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;\r
+import org.springframework.boot.web.servlet.FilterRegistrationBean;\r
+import org.springframework.boot.web.servlet.server.ConfigurableServletWebServerFactory;\r
+import org.springframework.context.annotation.Bean;\r
+import org.springframework.context.annotation.ComponentScan;\r
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;\r
+import org.springframework.jms.annotation.EnableJms;\r
+import org.springframework.jms.config.DefaultJmsListenerContainerFactory;\r
+import org.springframework.jms.config.JmsListenerContainerFactory;\r
+import org.springframework.jms.support.converter.MappingJackson2MessageConverter;\r
+import org.springframework.jms.support.converter.MessageConverter;\r
+import org.springframework.jms.support.converter.MessageType;\r
+import org.springframework.web.client.RestTemplate;\r
+\r
+@EnableJms\r
+@SpringBootApplication\r
+@ComponentScan({"org.commscope.tr069adapter.acs", "org.commscope.tr069adapter.common"})\r
+@EnableJpaRepositories("org.commscope.tr069adapter.acs")\r
+@EntityScan("org.commscope.tr069adapter.acs.requestprocessor.entity")\r
+public class ACSServiceBooter {\r
+\r
+ public static void main(String[] args) {\r
+ SpringApplication.run(ACSServiceBooter.class, args);\r
+ }\r
+\r
+ @Bean\r
+ public RestTemplate restTemplate(RestTemplateBuilder builder) {\r
+ return builder.build();\r
+ }\r
+\r
+\r
+ /*\r
+ * JMS Configuration Defining the connection factories used in the application Setting the\r
+ * Re-delivery configuration goes here\r
+ */\r
+ @Bean\r
+ public BrokerService broker() throws Exception {\r
+ final BrokerService broker = new BrokerService();\r
+ broker.addConnector("tcp://localhost:61616");\r
+ broker.addConnector("vm://localhost");\r
+ broker.setPersistent(false);\r
+ return broker;\r
+ }\r
+\r
+ @Bean\r
+ public ConnectionFactory jmsConnectionFactory() {\r
+ ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();\r
+ connectionFactory\r
+ .setTrustedPackages(Arrays.asList("org.commscope", "org.commscope.tr069adapter"));\r
+ connectionFactory.setMaxThreadPoolSize(7);\r
+\r
+ ActiveMQQueue tr069nbiReqQueue = new ActiveMQQueue(TR069_NBI_REQUEST_Q);\r
+ RedeliveryPolicy tr069nbiReqQueuePolicy = new RedeliveryPolicy();\r
+ tr069nbiReqQueuePolicy.setInitialRedeliveryDelay(30000);\r
+ tr069nbiReqQueuePolicy.setUseCollisionAvoidance(true);\r
+ tr069nbiReqQueuePolicy.setRedeliveryDelay(30000);\r
+ tr069nbiReqQueuePolicy.setUseExponentialBackOff(false);\r
+ tr069nbiReqQueuePolicy.setMaximumRedeliveries(3);\r
+ tr069nbiReqQueuePolicy.setDestination(tr069nbiReqQueue);\r
+\r
+ ActiveMQQueue crQueue = new ActiveMQQueue(CR_REQ_Q);\r
+ RedeliveryPolicy crQueuePolicy = new RedeliveryPolicy();\r
+ crQueuePolicy.setInitialRedeliveryDelay(18000);\r
+ crQueuePolicy.setUseCollisionAvoidance(true);\r
+ crQueuePolicy.setRedeliveryDelay(18000);\r
+ crQueuePolicy.setUseExponentialBackOff(true);\r
+ crQueuePolicy.setBackOffMultiplier(2);\r
+ crQueuePolicy.setMaximumRedeliveries(4);\r
+ crQueuePolicy.setDestination(crQueue);\r
+\r
+ ActiveMQQueue notificationQueue = new ActiveMQQueue(NBI_NOTIFICATION_Q);\r
+ RedeliveryPolicy notificationQueuePolicy = new RedeliveryPolicy();\r
+ notificationQueuePolicy.setInitialRedeliveryDelay(30000);\r
+ notificationQueuePolicy.setUseCollisionAvoidance(true);\r
+ notificationQueuePolicy.setRedeliveryDelay(30000);\r
+ notificationQueuePolicy.setUseExponentialBackOff(false);\r
+ notificationQueuePolicy.setMaximumRedeliveries(5);\r
+ notificationQueuePolicy.setDestination(notificationQueue);\r
+\r
+ ActiveMQQueue opResQueue = new ActiveMQQueue(NBI_OP_RESULT_Q);\r
+ RedeliveryPolicy opResQueuePolicy = new RedeliveryPolicy();\r
+ opResQueuePolicy.setInitialRedeliveryDelay(30000);\r
+ opResQueuePolicy.setUseCollisionAvoidance(true);\r
+ opResQueuePolicy.setRedeliveryDelay(30000);\r
+ opResQueuePolicy.setUseExponentialBackOff(false);\r
+ opResQueuePolicy.setMaximumRedeliveries(3);\r
+ opResQueuePolicy.setDestination(opResQueue);\r
+\r
+ RedeliveryPolicyMap rdMap = connectionFactory.getRedeliveryPolicyMap();\r
+ rdMap.put(tr069nbiReqQueue, tr069nbiReqQueuePolicy);\r
+ rdMap.put(crQueue, crQueuePolicy);\r
+ rdMap.put(notificationQueue, notificationQueuePolicy);\r
+ rdMap.put(opResQueue, opResQueuePolicy);\r
+\r
+ return connectionFactory;\r
+ }\r
+ // End\r
+\r
+\r
+ @Bean\r
+ public JmsListenerContainerFactory<?> tr069NBIRequestCF(ConnectionFactory connectionFactory,\r
+ DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
+ DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
+ configurer.configure(factory, connectionFactory);\r
+ return factory;\r
+ }\r
+\r
+ @Bean\r
+ public JmsListenerContainerFactory<?> tr069DeviceResponseCF(ConnectionFactory connectionFactory,\r
+ DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
+ DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
+ configurer.configure(factory, connectionFactory);\r
+ return factory;\r
+ }\r
+\r
+ @Bean\r
+ public JmsListenerContainerFactory<?> nbiNotificationCF(ConnectionFactory connectionFactory,\r
+ DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
+ DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
+ configurer.configure(factory, connectionFactory);\r
+ return factory;\r
+ }\r
+\r
+ @Bean\r
+ public JmsListenerContainerFactory<?> nbiOpResultCF(ConnectionFactory connectionFactory,\r
+ DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
+ DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
+ configurer.configure(factory, connectionFactory);\r
+ return factory;\r
+ }\r
+\r
+ /*\r
+ * JMS Configuration ends here\r
+ */\r
+\r
+ /*\r
+ * JMS serializing and de-serializing used Jackson JMS message converter Serialize message content\r
+ * to json using TextMessage\r
+ */\r
+ @Bean\r
+ public MessageConverter jacksonJmsMessageConverter() {\r
+ MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();\r
+ converter.setTargetType(MessageType.TEXT);\r
+ converter.setTypeIdPropertyName("_type");\r
+ return converter;\r
+ }\r
+\r
+ /*\r
+ * Exposing an addition HTTP port for Netconf mapper to access And making the default port to be\r
+ * TLS secured which shall be used in the hems url\r
+ */\r
+ @Value("${server.additional.http.port}")\r
+ private String additionalHttpPort;\r
+\r
+ @Value("${server.port}")\r
+ private String serverPort;\r
+\r
+ @Bean\r
+ public ConfigurableServletWebServerFactory tomcatEmbeddedServletContainerFactory() {\r
+ final TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory();\r
+ final Connector connector = new Connector(TomcatServletWebServerFactory.DEFAULT_PROTOCOL);\r
+ connector.setScheme("https");\r
+ connector.setPort(Integer.valueOf(this.additionalHttpPort));\r
+ factory.addAdditionalTomcatConnectors(connector);\r
+ return factory;\r
+ }\r
+\r
+ @Bean\r
+ public FilterRegistrationBean<FilterInsecuredRequests> loggingFilter() {\r
+ FilterRegistrationBean<FilterInsecuredRequests> registrationBean =\r
+ new FilterRegistrationBean<>();\r
+ registrationBean.setFilter(new FilterInsecuredRequests(serverPort));\r
+ registrationBean.addUrlPatterns("/CPEMgmt/*");\r
+ return registrationBean;\r
+ }\r
+\r
+}\r
Code Review / oam / tr069-adapter.git / blobdiff