--- /dev/null
+/* Copyright (c) 2019 AT&T Intellectual Property. #\r
+# #\r
+# Licensed under the Apache License, Version 2.0 (the "License"); #\r
+# you may not use this file except in compliance with the License. #\r
+# You may obtain a copy of the License at #\r
+# #\r
+# http://www.apache.org/licenses/LICENSE-2.0 #\r
+# #\r
+# Unless required by applicable law or agreed to in writing, software #\r
+# distributed under the License is distributed on an "AS IS" BASIS, #\r
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. #\r
+# See the License for the specific language governing permissions and #\r
+# limitations under the License. #\r
+##############################################################################*/\r
+\r
+\r
+package org.oran.otf.camunda.configuration;\r
+\r
+import com.google.common.base.Strings;\r
+import java.util.Optional;\r
+import java.util.UUID;\r
+import javax.sql.DataSource;\r
+import org.camunda.bpm.application.impl.event.ProcessApplicationEventListenerPlugin;\r
+import org.camunda.bpm.engine.ProcessEngineConfiguration;\r
+import org.camunda.bpm.engine.impl.cfg.IdGenerator;\r
+import org.camunda.bpm.engine.impl.cfg.ProcessEngineConfigurationImpl;\r
+import org.camunda.bpm.engine.impl.history.HistoryLevel;\r
+import org.camunda.bpm.engine.spring.SpringProcessEngineConfiguration;\r
+import org.camunda.bpm.extension.reactor.bus.CamundaEventBus;\r
+import org.camunda.bpm.extension.reactor.plugin.ReactorProcessEnginePlugin;\r
+import org.camunda.bpm.extension.reactor.projectreactor.EventBus;\r
+import org.camunda.bpm.spring.boot.starter.configuration.impl.DefaultProcessEngineConfiguration;\r
+import org.camunda.connect.plugin.impl.ConnectProcessEnginePlugin;\r
+import org.camunda.spin.plugin.impl.SpinProcessEnginePlugin;\r
+import org.springframework.beans.factory.annotation.Autowired;\r
+import org.springframework.beans.factory.annotation.Qualifier;\r
+import org.springframework.context.annotation.Bean;\r
+import org.springframework.context.annotation.Configuration;\r
+import org.springframework.transaction.PlatformTransactionManager;\r
+import org.springframework.util.StringUtils;\r
+\r
+@Configuration\r
+public class OtfCamundaConfiguration extends DefaultProcessEngineConfiguration {\r
+\r
+ @Autowired\r
+ private DataSource dataSource;\r
+ @Autowired\r
+ private PlatformTransactionManager transactionManager;\r
+ @Autowired private Optional<IdGenerator> idGenerator;\r
+\r
+ public static String processEngineName;\r
+\r
+ @Bean\r
+ public ProcessEngineConfiguration configureEngine(ProcessEngineConfigurationImpl configuration) {\r
+ configuration.setJavaSerializationFormatEnabled(true);\r
+ return configuration;\r
+ }\r
+\r
+ @Override\r
+ public void preInit(SpringProcessEngineConfiguration configuration) {\r
+\r
+ logger.info(configuration.getProcessEngineName());\r
+ processEngineName = System.getenv("HOSTNAME");\r
+ if (Strings.isNullOrEmpty(processEngineName)) {\r
+ processEngineName = "otf-camunda-" + UUID.randomUUID().toString();\r
+ }\r
+ processEngineName = processEngineName.replaceAll("-", "_");\r
+ camundaBpmProperties.setProcessEngineName(processEngineName);\r
+ camundaBpmProperties.setAutoDeploymentEnabled(true);\r
+ camundaBpmProperties.setHistoryLevel(HistoryLevel.HISTORY_LEVEL_FULL.getName());\r
+ camundaBpmProperties.setDefaultNumberOfRetries(1);\r
+\r
+ setProcessEngineName(configuration);\r
+ setDefaultSerializationFormat(configuration);\r
+ setIdGenerator(configuration);\r
+ setJobExecutorAcquireByPriority(configuration);\r
+ setDefaultNumberOfRetries(configuration);\r
+\r
+ configuration.setDataSource(dataSource);\r
+ configuration.setTransactionManager(transactionManager);\r
+ configuration.setHistory("true");\r
+ configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);\r
+ configuration.setJobExecutorActivate(true);\r
+ configuration.setCreateIncidentOnFailedJobEnabled(true);\r
+ configuration.setFailedJobListenerMaxRetries(0);\r
+ configuration.setJavaSerializationFormatEnabled(true);\r
+ configuration.setMetricsEnabled(false);\r
+ }\r
+\r
+ private void setIdGenerator(SpringProcessEngineConfiguration configuration) {\r
+ idGenerator.ifPresent(configuration::setIdGenerator);\r
+ }\r
+\r
+ private void setDefaultSerializationFormat(SpringProcessEngineConfiguration configuration) {\r
+ String defaultSerializationFormat = camundaBpmProperties.getDefaultSerializationFormat();\r
+ if (StringUtils.hasText(defaultSerializationFormat)) {\r
+ configuration.setDefaultSerializationFormat(defaultSerializationFormat);\r
+ } else {\r
+ logger.warn("Ignoring invalid defaultSerializationFormat='{}'", defaultSerializationFormat);\r
+ }\r
+ }\r
+\r
+ private void setProcessEngineName(SpringProcessEngineConfiguration configuration) {\r
+ String processEngineName =\r
+ StringUtils.trimAllWhitespace(camundaBpmProperties.getProcessEngineName());\r
+ if (!StringUtils.isEmpty(processEngineName) && !processEngineName.contains("-")) {\r
+ configuration.setProcessEngineName(processEngineName);\r
+ } else {\r
+ logger.warn(\r
+ "Ignoring invalid processEngineName='{}' - must not be null, blank or contain hyphen",\r
+ camundaBpmProperties.getProcessEngineName());\r
+ }\r
+ }\r
+\r
+ private void setJobExecutorAcquireByPriority(SpringProcessEngineConfiguration configuration) {\r
+ Optional.ofNullable(camundaBpmProperties.getJobExecutorAcquireByPriority())\r
+ .ifPresent(configuration::setJobExecutorAcquireByPriority);\r
+ }\r
+\r
+ private void setDefaultNumberOfRetries(SpringProcessEngineConfiguration configuration) {\r
+ Optional.ofNullable(camundaBpmProperties.getDefaultNumberOfRetries())\r
+ .ifPresent(configuration::setDefaultNumberOfRetries);\r
+ }\r
+\r
+ @Bean\r
+ CamundaEventBus camundaEventBus() {\r
+ return new CamundaEventBus();\r
+ }\r
+\r
+ @Bean\r
+ @Qualifier("camunda")\r
+ EventBus eventBus(final CamundaEventBus camundaEventBus) {\r
+ return camundaEventBus.get();\r
+ }\r
+\r
+ @Bean\r
+ ReactorProcessEnginePlugin reactorProcessEnginePlugin(final CamundaEventBus camundaEventBus) {\r
+ return new ReactorProcessEnginePlugin(camundaEventBus);\r
+ }\r
+\r
+ @Bean\r
+ ConnectProcessEnginePlugin connectProcessEnginePlugin() {\r
+ return new ConnectProcessEnginePlugin();\r
+ }\r
+\r
+ @Bean\r
+ SpinProcessEnginePlugin spinProcessEnginePlugin() {\r
+ return new SpinProcessEnginePlugin();\r
+ }\r
+\r
+ @Bean\r
+ ProcessApplicationEventListenerPlugin processApplicationEventListenerPlugin() {\r
+ return new ProcessApplicationEventListenerPlugin();\r
+ }\r
+}\r