so-etsi-nfvo/so-etsi-nfvo-ns-lcm/so-etsi-nfvo-ns-lcm-bpmn-flows/src/main/java/org/onap/so/etsi/nfvo/ns/lcm/bpmn/flows/CamundaDatabaseConfiguration.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2020 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20 package org.onap.so.etsi.nfvo.ns.lcm.bpmn.flows;
  21
  22
  23 import static org.slf4j.LoggerFactory.getLogger;
  24 import javax.sql.DataSource;
  25 import org.camunda.bpm.engine.spring.SpringProcessEngineConfiguration;
  26 import org.camunda.bpm.spring.boot.starter.util.SpringBootProcessEnginePlugin;
  27 import org.slf4j.Logger;
  28 import org.springframework.beans.factory.annotation.Autowired;
  29 import org.springframework.beans.factory.annotation.Qualifier;
  30 import org.springframework.boot.context.properties.ConfigurationProperties;
  31 import org.springframework.context.annotation.Bean;
  32 import org.springframework.context.annotation.Configuration;
  33 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
  34 import org.springframework.jmx.export.MBeanExporter;
  35 import org.springframework.transaction.PlatformTransactionManager;
  36 import org.springframework.transaction.annotation.EnableTransactionManagement;
  37 import com.zaxxer.hikari.HikariConfig;
  38 import com.zaxxer.hikari.HikariDataSource;
  39
  40 /**
  41  * @author Waqas Ikram (waqas.ikram@est.tech)
  42  *
  43  */
  44 @Configuration
  45 @EnableTransactionManagement
  46 public class CamundaDatabaseConfiguration {
  47
  48     private static final String CAMUNDA_TRANSACTION_MANAGER_BEAN_NAME = "camundaTransactionManager";
  49
  50     private static final String CAMUNDA_DATA_SOURCE_BEAN_NAME = "camundaBpmDataSource";
  51
  52     private static final Logger logger = getLogger(CamundaDatabaseConfiguration.class);
  53
  54     @Autowired(required = false)
  55     private MBeanExporter mBeanExporter;
  56
  57     @Bean
  58     @ConfigurationProperties(prefix = "spring.datasource.hikari.camunda")
  59     public HikariConfig camundaDbConfig() {
  60         logger.debug("Creating Camunda HikariConfig bean ... ");
  61         return new HikariConfig();
  62     }
  63
  64     @Bean(name = CAMUNDA_DATA_SOURCE_BEAN_NAME)
  65     public DataSource camundaDataSource() {
  66         if (mBeanExporter != null) {
  67             mBeanExporter.addExcludedBean(CAMUNDA_DATA_SOURCE_BEAN_NAME);
  68         }
  69         logger.debug("Creating Camunda HikariDataSource bean ... ");
  70         final HikariConfig hikariConfig = this.camundaDbConfig();
  71         return new HikariDataSource(hikariConfig);
  72     }
  73
  74     @Bean(name = CAMUNDA_TRANSACTION_MANAGER_BEAN_NAME)
  75     public PlatformTransactionManager camundaTransactionManager(
  76             @Qualifier(CAMUNDA_DATA_SOURCE_BEAN_NAME) final DataSource dataSource) {
  77         return new DataSourceTransactionManager(dataSource);
  78     }
  79
  80     @Bean
  81     public SpringBootProcessEnginePlugin transactionManagerProcessEnginePlugin(
  82             @Qualifier(CAMUNDA_TRANSACTION_MANAGER_BEAN_NAME) final PlatformTransactionManager camundaTransactionManager) {
  83         return new SpringBootProcessEnginePlugin() {
  84             @Override
  85             public void preInit(final SpringProcessEngineConfiguration processEngineConfiguration) {
  86                 logger.info("Setting Camunda TransactionManager ...");
  87                 processEngineConfiguration.setTransactionManager(camundaTransactionManager);
  88
  89             }
  90         };
  91     }
  92 }