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.listener.MessageListenerContainer;\r
  52 import org.springframework.jms.support.converter.MappingJackson2MessageConverter;\r
  53 import org.springframework.jms.support.converter.MessageConverter;\r
  54 import org.springframework.jms.support.converter.MessageType;\r
  55 import org.springframework.web.client.RestTemplate;\r
  56 \r
  57 @EnableJms\r
  58 @SpringBootApplication\r
  59 @ComponentScan({"org.commscope.tr069adapter.acs", "org.commscope.tr069adapter.common"})\r
  60 @EnableJpaRepositories("org.commscope.tr069adapter.acs")\r
  61 @EntityScan("org.commscope.tr069adapter.acs.requestprocessor.entity")\r
  62 public class ACSServiceBooter {\r
  63 \r
  64   public static void main(String[] args) {\r
  65     SpringApplication.run(ACSServiceBooter.class, args);\r
  66   }\r
  67 \r
  68   @Bean\r
  69   public RestTemplate restTemplate(RestTemplateBuilder builder) {\r
  70     return builder.build();\r
  71   }\r
  72 \r
  73 \r
  74   /*\r
  75    * JMS Configuration Defining the connection factories used in the application Setting the\r
  76    * Re-delivery configuration goes here\r
  77    */\r
  78   @Bean\r
  79   public BrokerService broker() throws Exception {\r
  80     final BrokerService broker = new BrokerService();\r
  81     broker.addConnector("tcp://localhost:61616");\r
  82     broker.addConnector("vm://localhost");\r
  83     broker.setPersistent(false);\r
  84     return broker;\r
  85   }\r
  86 \r
  87   @Bean\r
  88   public ConnectionFactory jmsConnectionFactory() {\r
  89     ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();\r
  90     connectionFactory\r
  91         .setTrustedPackages(Arrays.asList("org.commscope", "org.commscope.tr069adapter"));\r
  92     connectionFactory.setMaxThreadPoolSize(7);\r
  93 \r
  94     ActiveMQQueue tr069nbiReqQueue = new ActiveMQQueue(TR069_NBI_REQUEST_Q);\r
  95     RedeliveryPolicy tr069nbiReqQueuePolicy = new RedeliveryPolicy();\r
  96     tr069nbiReqQueuePolicy.setInitialRedeliveryDelay(30000);\r
  97     tr069nbiReqQueuePolicy.setUseCollisionAvoidance(true);\r
  98     tr069nbiReqQueuePolicy.setRedeliveryDelay(30000);\r
  99     tr069nbiReqQueuePolicy.setUseExponentialBackOff(false);\r
 100     tr069nbiReqQueuePolicy.setMaximumRedeliveries(3);\r
 101     tr069nbiReqQueuePolicy.setDestination(tr069nbiReqQueue);\r
 102 \r
 103     ActiveMQQueue crQueue = new ActiveMQQueue(CR_REQ_Q);\r
 104     RedeliveryPolicy crQueuePolicy = new RedeliveryPolicy();\r
 105     crQueuePolicy.setInitialRedeliveryDelay(18000);\r
 106     crQueuePolicy.setUseCollisionAvoidance(true);\r
 107     crQueuePolicy.setRedeliveryDelay(18000);\r
 108     crQueuePolicy.setUseExponentialBackOff(true);\r
 109     crQueuePolicy.setBackOffMultiplier(2);\r
 110     crQueuePolicy.setMaximumRedeliveries(4);\r
 111     crQueuePolicy.setDestination(crQueue);\r
 112 \r
 113     ActiveMQQueue notificationQueue = new ActiveMQQueue(NBI_NOTIFICATION_Q);\r
 114     RedeliveryPolicy notificationQueuePolicy = new RedeliveryPolicy();\r
 115     notificationQueuePolicy.setInitialRedeliveryDelay(30000);\r
 116     notificationQueuePolicy.setUseCollisionAvoidance(true);\r
 117     notificationQueuePolicy.setRedeliveryDelay(30000);\r
 118     notificationQueuePolicy.setUseExponentialBackOff(false);\r
 119     notificationQueuePolicy.setMaximumRedeliveries(5);\r
 120     notificationQueuePolicy.setDestination(notificationQueue);\r
 121 \r
 122     ActiveMQQueue opResQueue = new ActiveMQQueue(NBI_OP_RESULT_Q);\r
 123     RedeliveryPolicy opResQueuePolicy = new RedeliveryPolicy();\r
 124     opResQueuePolicy.setInitialRedeliveryDelay(30000);\r
 125     opResQueuePolicy.setUseCollisionAvoidance(true);\r
 126     opResQueuePolicy.setRedeliveryDelay(30000);\r
 127     opResQueuePolicy.setUseExponentialBackOff(false);\r
 128     opResQueuePolicy.setMaximumRedeliveries(3);\r
 129     opResQueuePolicy.setDestination(opResQueue);\r
 130 \r
 131     RedeliveryPolicyMap rdMap = connectionFactory.getRedeliveryPolicyMap();\r
 132     rdMap.put(tr069nbiReqQueue, tr069nbiReqQueuePolicy);\r
 133     rdMap.put(crQueue, crQueuePolicy);\r
 134     rdMap.put(notificationQueue, notificationQueuePolicy);\r
 135     rdMap.put(opResQueue, opResQueuePolicy);\r
 136 \r
 137     return connectionFactory;\r
 138   }\r
 139   // End\r
 140 \r
 141   @Bean\r
 142   public JmsListenerContainerFactory<MessageListenerContainer> tr069NBIRequestCF(\r
 143       ConnectionFactory connectionFactory,\r
 144       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 145     return handleJMSCommonConfiguration(connectionFactory, configurer);\r
 146   }\r
 147 \r
 148   @Bean\r
 149   public JmsListenerContainerFactory<MessageListenerContainer> tr069DeviceResponseCF(\r
 150       ConnectionFactory connectionFactory,\r
 151       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 152     return handleJMSCommonConfiguration(connectionFactory, configurer);\r
 153   }\r
 154 \r
 155   @Bean\r
 156   public JmsListenerContainerFactory<MessageListenerContainer> nbiNotificationCF(\r
 157       ConnectionFactory connectionFactory,\r
 158       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 159     return handleJMSCommonConfiguration(connectionFactory, configurer);\r
 160   }\r
 161 \r
 162   @Bean\r
 163   public JmsListenerContainerFactory<MessageListenerContainer> nbiOpResultCF(\r
 164       ConnectionFactory connectionFactory,\r
 165       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 166     return handleJMSCommonConfiguration(connectionFactory, configurer);\r
 167   }\r
 168 \r
 169   public JmsListenerContainerFactory handleJMSCommonConfiguration(\r
 170       ConnectionFactory connectionFactory,\r
 171       DefaultJmsListenerContainerFactoryConfigurer configurer) {\r
 172     DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r
 173     configurer.configure(factory, connectionFactory);\r
 174     return factory;\r
 175   }\r
 176 \r
 177   /*\r
 178    * JMS Configuration ends here\r
 179    */\r
 180 \r
 181   /*\r
 182    * JMS serializing and de-serializing used Jackson JMS message converter Serialize message content\r
 183    * to json using TextMessage\r
 184    */\r
 185   @Bean\r
 186   public MessageConverter jacksonJmsMessageConverter() {\r
 187     MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();\r
 188     converter.setTargetType(MessageType.TEXT);\r
 189     converter.setTypeIdPropertyName("_type");\r
 190     return converter;\r
 191   }\r
 192 \r
 193   /*\r
 194    * Exposing an addition HTTP port for Netconf mapper to access And making the default port to be\r
 195    * TLS secured which shall be used in the hems url\r
 196    */\r
 197   @Value("${server.additional.http.port}")\r
 198   private String additionalHttpPort;\r
 199 \r
 200   @Value("${server.port}")\r
 201   private String serverPort;\r
 202 \r
 203   @Bean\r
 204   public ConfigurableServletWebServerFactory tomcatEmbeddedServletContainerFactory() {\r
 205     final TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory();\r
 206     final Connector connector = new Connector(TomcatServletWebServerFactory.DEFAULT_PROTOCOL);\r
 207     connector.setScheme("https");\r
 208     connector.setPort(Integer.valueOf(this.additionalHttpPort));\r
 209     factory.addAdditionalTomcatConnectors(connector);\r
 210     return factory;\r
 211   }\r
 212 \r
 213   @Bean\r
 214   public FilterRegistrationBean<FilterInsecuredRequests> loggingFilter() {\r
 215     FilterRegistrationBean<FilterInsecuredRequests> registrationBean =\r
 216         new FilterRegistrationBean<>();\r
 217     registrationBean.setFilter(new FilterInsecuredRequests(serverPort));\r
 218     registrationBean.addUrlPatterns("/CPEMgmt/*");\r
 219     return registrationBean;\r
 220   }\r
 221 \r
 222 }\r