acs/application-booter/src/main/java/org/commscope/tr069adapter/acs/booter/ACSServiceBooter.java

   1 /*\r
   2  * ============LICENSE_START========================================================================\r
   3  * ONAP : tr-069-adapter\r
   4  * =================================================================================================\r
   5  * Copyright (C) 2020 CommScope Inc Intellectual Property.\r
   6  * =================================================================================================\r
   7  * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License,\r
   8  * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You\r
   9  * may obtain a copy of the License at\r
  10  *\r
  11  * http://www.apache.org/licenses/LICENSE-2.0\r
  12  *\r
  13  * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,\r
  14  * either express or implied. See the License for the specific language governing permissions and\r
  15  * limitations under the License.\r
  16  * ===============LICENSE_END=======================================================================\r
  17  */\r
  18 \r
  19 package org.commscope.tr069adapter.acs.booter;\r
  20 \r
  21 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.CR_REQ_Q;\r
  22 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_NOTIFICATION_Q;\r
  23 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.NBI_OP_RESULT_Q;\r
  24 import static org.commscope.tr069adapter.acs.common.utils.AcsConstants.TR069_NBI_REQUEST_Q;\r
  25 \r
  26 import java.util.Arrays;\r
  27 \r
  28 import javax.jms.ConnectionFactory;\r
  29 \r
  30 import org.apache.activemq.ActiveMQConnectionFactory;\r
  31 import org.apache.activemq.RedeliveryPolicy;\r
  32 import org.apache.activemq.broker.BrokerService;\r
  33 import org.apache.activemq.broker.region.policy.RedeliveryPolicyMap;\r
  34 import org.apache.activemq.command.ActiveMQQueue;\r
  35 import org.apache.catalina.connector.Connector;\r
  36 import org.springframework.beans.factory.annotation.Value;\r
  37 import org.springframework.boot.SpringApplication;\r
  38 import org.springframework.boot.autoconfigure.SpringBootApplication;\r
  39 import org.springframework.boot.autoconfigure.domain.EntityScan;\r
  40 import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;\r
  41 import org.springframework.boot.web.client.RestTemplateBuilder;\r
  42 import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;\r
  43 import org.springframework.boot.web.servlet.FilterRegistrationBean;\r
  44 import org.springframework.boot.web.servlet.server.ConfigurableServletWebServerFactory;\r
  45 import org.springframework.context.annotation.Bean;\r
  46 import org.springframework.context.annotation.ComponentScan;\r
  47 import org.springframework.data.jpa.repository.config.EnableJpaRepositories;\r
  48 import org.springframework.jms.annotation.EnableJms;\r
  49 import org.springframework.jms.config.DefaultJmsListenerContainerFactory;\r
  50 import org.springframework.jms.config.JmsListenerContainerFactory;\r
  51 import org.springframework.jms.support.converter.MappingJackson2MessageConverter;\r
  52 import org.springframework.jms.support.converter.MessageConverter;\r
  53 import org.springframework.jms.support.converter.MessageType;\r
  54 import org.springframework.web.client.RestTemplate;\r
  55 \r
  56 @EnableJms\r
  57 @SpringBootApplication\r
  58 @ComponentScan({"org.commscope.tr069adapter.acs", "org.commscope.tr069adapter.common"})\r
  59 @EnableJpaRepositories("org.commscope.tr069adapter.acs")\r
  60 @EntityScan("org.commscope.tr069adapter.acs.requestprocessor.entity")\r
  61 public class ACSServiceBooter {\r
  62 \r
  63   public static void main(String[] args) {\r
  64     SpringApplication.run(ACSServiceBooter.class, args);\r
  65   }\r
  66 \r
  67   @Bean\r
  68   public RestTemplate restTemplate(RestTemplateBuilder builder) {\r
  69     return builder.build();\r
  70   }\r
  71 \r
  72 \r
  73   /*\r
  74    * JMS Configuration Defining the connection factories used in the application Setting the\r
  75    * Re-delivery configuration goes here\r
  76    */\r
  77   @Bean\r
  78   public BrokerService broker() throws Exception {\r
  79     final BrokerService broker = new BrokerService();\r
  80     broker.addConnector("tcp://localhost:61616");\r
  81     broker.addConnector("vm://localhost");\r
  82     broker.setPersistent(false);\r
  83     return broker;\r
  84   }\r
  85 \r
  86   @Bean\r
  87   public ConnectionFactory jmsConnectionFactory() {\r
  88     ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();\r
  89     connectionFactory\r
  90         .setTrustedPackages(Arrays.asList("org.commscope", "org.commscope.tr069adapter"));\r
  91     connectionFactory.setMaxThreadPoolSize(7);\r
  92 \r
  93     ActiveMQQueue tr069nbiReqQueue = new ActiveMQQueue(TR069_NBI_REQUEST_Q);\r
  94     RedeliveryPolicy tr069nbiReqQueuePolicy = new RedeliveryPolicy();\r
  95     tr069nbiReqQueuePolicy.setInitialRedeliveryDelay(30000);\r
  96     tr069nbiReqQueuePolicy.setUseCollisionAvoidance(true);\r
  97     tr069nbiReqQueuePolicy.setRedeliveryDelay(30000);\r
  98     tr069nbiReqQueuePolicy.setUseExponentialBackOff(false);\r
  99     tr069nbiReqQueuePolicy.setMaximumRedeliveries(3);\r
 100     tr069nbiReqQueuePolicy.setDestination(tr069nbiReqQueue);\r
 101 \r
 102     ActiveMQQueue crQueue = new ActiveMQQueue(CR_REQ_Q);\r
 103     RedeliveryPolicy crQueuePolicy = new RedeliveryPolicy();\r
 104     crQueuePolicy.setInitialRedeliveryDelay(18000);\r
 105     crQueuePolicy.setUseCollisionAvoidance(true);\r
 106     crQueuePolicy.setRedeliveryDelay(18000);\r
 107     crQueuePolicy.setUseExponentialBackOff(true);\r
 108     crQueuePolicy.setBackOffMultiplier(2);\r
 109     crQueuePolicy.setMaximumRedeliveries(4);\r
 110     crQueuePolicy.setDestination(crQueue);\r
 111 \r
 112     ActiveMQQueue notificationQueue = new ActiveMQQueue(NBI_NOTIFICATION_Q);\r
 113     RedeliveryPolicy notificationQueuePolicy = new RedeliveryPolicy();\r
 114     notificationQueuePolicy.setInitialRedeliveryDelay(30000);\r
 115     notificationQueuePolicy.setUseCollisionAvoidance(true);\r
 116     notificationQueuePolicy.setRedeliveryDelay(30000);\r
 117     notificationQueuePolicy.setUseExponentialBackOff(false);\r
 118     notificationQueuePolicy.setMaximumRedeliveries(5);\r
 119     notificationQueuePolicy.setDestination(notificationQueue);\r
 120 \r
 121     ActiveMQQueue opResQueue = new ActiveMQQueue(NBI_OP_RESULT_Q);\r
 122     RedeliveryPolicy opResQueuePolicy = new RedeliveryPolicy();\r
 123     opResQueuePolicy.setInitialRedeliveryDelay(30000);\r
 124     opResQueuePolicy.setUseCollisionAvoidance(true);\r
 125     opResQueuePolicy.setRedeliveryDelay(30000);\r
 126     opResQueuePolicy.setUseExponentialBackOff(false);\r
 127     opResQueuePolicy.setMaximumRedeliveries(3);\r
 128     opResQueuePolicy.setDestination(opResQueue);\r
 129 \r
 130     RedeliveryPolicyMap rdMap = connectionFactory.getRedeliveryPolicyMap();\r
 131     rdMap.put(tr069nbiReqQueue, tr069nbiReqQueuePolicy);\r
 132     rdMap.put(crQueue, crQueuePolicy);\r
 133     rdMap.put(notificationQueue, notificationQueuePolicy);\r
 134     rdMap.put(opResQueue, opResQueuePolicy);\r
 135 \r
 136     return connectionFactory;\r
 137   }\r
 138   // End\r
 139 \r
 140 \r
 141   @Bean\r
 142   public JmsListenerContainerFactory<?> tr069NBIRequestCF(ConnectionFactory connectionFactory,\r
 143       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 144     DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
 145     configurer.configure(factory, connectionFactory);\r
 146     return factory;\r
 147   }\r
 148 \r
 149   @Bean\r
 150   public JmsListenerContainerFactory<?> tr069DeviceResponseCF(ConnectionFactory connectionFactory,\r
 151       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 152     DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
 153     configurer.configure(factory, connectionFactory);\r
 154     return factory;\r
 155   }\r
 156 \r
 157   @Bean\r
 158   public JmsListenerContainerFactory<?> nbiNotificationCF(ConnectionFactory connectionFactory,\r
 159       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 160     DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
 161     configurer.configure(factory, connectionFactory);\r
 162     return factory;\r
 163   }\r
 164 \r
 165   @Bean\r
 166   public JmsListenerContainerFactory<?> nbiOpResultCF(ConnectionFactory connectionFactory,\r
 167       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 168     DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
 169     configurer.configure(factory, connectionFactory);\r
 170     return factory;\r
 171   }\r
 172 \r
 173   /*\r
 174    * JMS Configuration ends here\r
 175    */\r
 176 \r
 177   /*\r
 178    * JMS serializing and de-serializing used Jackson JMS message converter Serialize message content\r
 179    * to json using TextMessage\r
 180    */\r
 181   @Bean\r
 182   public MessageConverter jacksonJmsMessageConverter() {\r
 183     MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();\r
 184     converter.setTargetType(MessageType.TEXT);\r
 185     converter.setTypeIdPropertyName("_type");\r
 186     return converter;\r
 187   }\r
 188 \r
 189   /*\r
 190    * Exposing an addition HTTP port for Netconf mapper to access And making the default port to be\r
 191    * TLS secured which shall be used in the hems url\r
 192    */\r
 193   @Value("${server.additional.http.port}")\r
 194   private String additionalHttpPort;\r
 195 \r
 196   @Value("${server.port}")\r
 197   private String serverPort;\r
 198 \r
 199   @Bean\r
 200   public ConfigurableServletWebServerFactory tomcatEmbeddedServletContainerFactory() {\r
 201     final TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory();\r
 202     final Connector connector = new Connector(TomcatServletWebServerFactory.DEFAULT_PROTOCOL);\r
 203     connector.setScheme("https");\r
 204     connector.setPort(Integer.valueOf(this.additionalHttpPort));\r
 205     factory.addAdditionalTomcatConnectors(connector);\r
 206     return factory;\r
 207   }\r
 208 \r
 209   @Bean\r
 210   public FilterRegistrationBean<FilterInsecuredRequests> loggingFilter() {\r
 211     FilterRegistrationBean<FilterInsecuredRequests> registrationBean =\r
 212         new FilterRegistrationBean<>();\r
 213     registrationBean.setFilter(new FilterInsecuredRequests(serverPort));\r
 214     registrationBean.addUrlPatterns("/CPEMgmt/*");\r
 215     return registrationBean;\r
 216   }\r
 217 \r
 218 }\r