解决springboot 集成activiti 计时器JobExecutor 不执行问题

  • Post author:
  • Post category:其他


package com.activiti.config;

import org.activiti.engine.*;

import org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl;

import org.activiti.rest.common.application.ContentTypeResolver;

import org.activiti.rest.common.application.DefaultContentTypeResolver;

import org.activiti.spring.ProcessEngineFactoryBean;

import org.activiti.spring.SpringProcessEngineConfiguration;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.transaction.PlatformTransactionManager;

import javax.sql.DataSource;


@Configuration

public class Cfg_Activiti {

//流程配置,与spring整合采用SpringProcessEngineConfiguration这个实现

@Bean

public ProcessEngineConfiguration processEngineConfiguration(DataSource dataSource, PlatformTransactionManager transactionManager){


SpringProcessEngineConfiguration processEngineConfiguration = new SpringProcessEngineConfiguration();

processEngineConfiguration.setDataSource(dataSource);

processEngineConfiguration.setDatabaseSchemaUpdate(“true”);

processEngineConfiguration.setDatabaseType(“mysql”);

processEngineConfiguration.setTransactionManager(transactionManager);

//流程图字体

processEngineConfiguration.setActivityFontName(“宋体”);

processEngineConfiguration.setAnnotationFontName(“宋体”);

processEngineConfiguration.setLabelFontName(“宋体”);

//processEngineConfiguration.setJobExecutorActivate(true);//JobExecutor是管理几个线程计时器的组成部分,JobExecutor对多线程的处理较为笨重缓慢


processEngineConfiguration.setAsyncExecutorEnabled(true);//定义为true,使用AsyncExecutor代替默认的JobExecutor;

processEngineConfiguration.setAsyncExecutorActivate(true);//定义为true,工作流引擎在启动时就建立启动AsyncExecutor线程

return processEngineConfiguration;

}

//流程引擎,与spring整合使用factoryBean

@Bean

public ProcessEngineFactoryBean processEngine(ProcessEngineConfiguration processEngineConfiguration){


ProcessEngineFactoryBean processEngineFactoryBean = new ProcessEngineFactoryBean();

processEngineFactoryBean.setProcessEngineConfiguration((ProcessEngineConfigurationImpl) processEngineConfiguration);

return processEngineFactoryBean;

}

//八大接口

@Bean

public RepositoryService repositoryService(ProcessEngine processEngine){


return processEngine.getRepositoryService();

}

@Bean

public RuntimeService runtimeService(ProcessEngine processEngine){


return processEngine.getRuntimeService();

}

@Bean

public TaskService taskService(ProcessEngine processEngine){


return processEngine.getTaskService();

}

@Bean

public HistoryService historyService(ProcessEngine processEngine){


return processEngine.getHistoryService();

}

@Bean

public FormService formService(ProcessEngine processEngine){


return processEngine.getFormService();

}

@Bean

public IdentityService identityService(ProcessEngine processEngine){


return processEngine.getIdentityService();

}

@Bean

public ManagementService managementService(ProcessEngine processEngine){


return processEngine.getManagementService();

}

@Bean

public DynamicBpmnService dynamicBpmnService(ProcessEngine processEngine){


return processEngine.getDynamicBpmnService();

}

//八大接口 end

}



版权声明:本文为iamcuilong原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。