import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
public ProcessEngineConfigurationImpl processEngineConfiguration() throws IOException {
    SpringProcessEngineConfiguration config = new SpringProcessEngineConfiguration();
    config.setDataSource(dataSource());
    config.setTransactionManager(transactionManager());
    config.setDatabaseSchemaUpdate("true");
    config.setJobExecutorActivate(true);
    config.setAuthorizationEnabled(true);
    config.setDefaultSerializationFormat("application/json");
    PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
    config.setDeploymentResources(resolver.getResources("classpath:/bpmn/*.bpmn"));
    List<ProcessEnginePlugin> processEnginePlugins = new ArrayList<>();
    SpinProcessEnginePlugin spinProcessEnginePlugin = new SpinProcessEnginePlugin();
    processEnginePlugins.add(spinProcessEnginePlugin);
    processEnginePlugins.add(CamundaReactor.plugin());
    config.setProcessEnginePlugins(processEnginePlugins);
    return config;
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
/**
 * Gets EventBus from given process engine via plugin.
 *
 * @param processEngine the process engine
 * @return the camunda eventBus
 */
public static CamundaEventBus eventBus(final ProcessEngine processEngine) {
  final ProcessEngineConfigurationImpl configuration = (ProcessEngineConfigurationImpl) processEngine.getProcessEngineConfiguration();
  final List<ProcessEnginePlugin> plugins = Optional.ofNullable(configuration.getProcessEnginePlugins()).orElse(Collections.EMPTY_LIST);

  final Function<List<ProcessEnginePlugin>, Optional<CamundaEventBus>> filterReactorPlugin = l -> l.stream()
    .filter(plugin -> plugin instanceof ReactorProcessEnginePlugin)
    .map(ReactorProcessEnginePlugin.class::cast)
    .map(ReactorProcessEnginePlugin::getEventBus)
    .findFirst();

  Optional<CamundaEventBus> reactorProcessEnginePlugin = filterReactorPlugin.apply(plugins);
  if (reactorProcessEnginePlugin.isPresent()) {
    return reactorProcessEnginePlugin.get();
  }

  return plugins.stream()
    .filter(plugin -> plugin instanceof CompositeProcessEnginePlugin)
    .map(CompositeProcessEnginePlugin.class::cast)
    .map(CompositeProcessEnginePlugin::getPlugins)
    .map(filterReactorPlugin)
    .flatMap(o -> o.map(Stream::of).orElseGet(Stream::empty))
    .findFirst()
    .orElseThrow(illegalState("No eventBus found. Make sure the Reactor plugin is configured correctly."));
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Before
public void initialize() {
  ElasticSearchHistoryPluginConfiguration historyPluginConfiguration = ElasticSearchHistoryPluginConfiguration.readConfigurationFromClasspath();
  ElasticSearchHelper.checkIndex(client, historyPluginConfiguration.getIndex());
  ElasticSearchHelper.checkTypeAndMapping(client, historyPluginConfiguration.getIndex(), historyPluginConfiguration.getType());

  List<ProcessEnginePlugin> processEnginePlugins = ((ProcessEngineImpl) processEngineRule.getProcessEngine())
      .getProcessEngineConfiguration()
      .getProcessEnginePlugins();
  for (ProcessEnginePlugin processEnginePlugin : processEnginePlugins) {
    if (processEnginePlugin instanceof ElasticSearchHistoryPlugin) {
      ElasticSearchHistoryPlugin plugin = (ElasticSearchHistoryPlugin) processEnginePlugin;
      plugin.setElasticSearchClient(client);
    }
  }
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
protected static void createClient(ProcessEngine processEngine) {
  List<ProcessEnginePlugin> processEnginePlugins = ((ProcessEngineImpl) processEngine).getProcessEngineConfiguration()
    .getProcessEnginePlugins();

  // check whether process enigne has elastic search plugin configured
  for (ProcessEnginePlugin processEnginePlugin : processEnginePlugins) {
    if (processEnginePlugin instanceof ElasticSearchHistoryPlugin) {
      ElasticSearchHistoryPlugin historyPlugin = (ElasticSearchHistoryPlugin) processEnginePlugin;
      cachedClient = historyPlugin.getElasticSearchClient();
      break;
    }
  }

  if(cachedClient == null) {
    // create new client from classpath configuration
    ElasticSearchHistoryPluginConfiguration elasticSearchPluginConfiguration = ElasticSearchHistoryPluginConfiguration.readConfigurationFromClasspath();
    cachedClient = new ElasticSearchClient(elasticSearchPluginConfiguration);
  }
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
/**
 * <p>Instantiates and applies all {@link ProcessEnginePlugin}s defined in the processEngineXml
 */
protected void configurePlugins(ProcessEngineConfigurationImpl configuration, ProcessEngineXml processEngineXml, ClassLoader classLoader) {

  for (ProcessEnginePluginXml pluginXml : processEngineXml.getPlugins()) {
    // create plugin instance
    Class<? extends ProcessEnginePlugin> pluginClass = loadClass(pluginXml.getPluginClass(), classLoader, ProcessEnginePlugin.class);
    ProcessEnginePlugin plugin = createInstance(pluginClass);

    // apply configured properties
    Map<String, String> properties = pluginXml.getProperties();
    PropertyHelper.applyProperties(plugin, properties);

    // add to configuration
    configuration.getProcessEnginePlugins().add(plugin);
  }

}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Test
public void spinPluginShouldBeRegistered() {

  List<ProcessEnginePlugin> processEnginePlugins = processEngineConfiguration.getProcessEnginePlugins();

  boolean spinPluginFound = false;

  for (ProcessEnginePlugin plugin : processEnginePlugins) {
    if (plugin.getClass().getName().contains("Spin")) {
      spinPluginFound = true;
      break;
    }
  }

  Assert.assertTrue(spinPluginFound);
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(ProcessEngineConfigurationImpl.class)
public ProcessEngineConfigurationImpl processEngineConfigurationImpl(List<ProcessEnginePlugin> processEnginePlugins) {
  final SpringProcessEngineConfiguration configuration = CamundaSpringBootUtil.springProcessEngineConfiguration();

  configuration.getProcessEnginePlugins().add(new CompositeProcessEnginePlugin(processEnginePlugins));

  return configuration;
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Test
public void processEngineConfigurationImplTest() {
  CamundaBpmConfiguration camundaBpmConfiguration = new CamundaBpmConfiguration();
  List<ProcessEnginePlugin> processEnginePlugins = createUnordedList();
  ProcessEngineConfigurationImpl processEngineConfigurationImpl = camundaBpmConfiguration.processEngineConfigurationImpl(processEnginePlugins);

  CompositeProcessEnginePlugin compositeProcessEnginePlugin = (CompositeProcessEnginePlugin) processEngineConfigurationImpl.getProcessEnginePlugins().get(0);
  assertThat(compositeProcessEnginePlugin.getPlugins()).isEqualTo(processEnginePlugins);
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
public StandaloneInMemoryTestConfiguration(List<ProcessEnginePlugin> plugins) {
  jobExecutorActivate = false;
  expressionManager = new MockExpressionManager();
  databaseSchemaUpdate = DB_SCHEMA_UPDATE_DROP_CREATE;
  isDbMetricsReporterActivate = false;

  getProcessEnginePlugins().addAll(plugins);
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
public static void main(String[] args) {

    // start process engine
    StandaloneInMemProcessEngineConfiguration processEngineConfiguration = new StandaloneInMemProcessEngineConfiguration();
    processEngineConfiguration.setProcessEngineName(ProcessEngines.NAME_DEFAULT);

    // add plugins
    List<ProcessEnginePlugin> processEnginePlugins = processEngineConfiguration.getProcessEnginePlugins();
    processEnginePlugins.add(new DebuggerPlugin());
    processEnginePlugins.add(new SpinProcessEnginePlugin());
    processEnginePlugins.add(new ConnectProcessEnginePlugin());

    processEngineConfiguration.buildProcessEngine();

    DebugSessionFactory.getInstance().setSuspend(false);

    // start debug server
    DebugWebsocket debugWebsocket = null;
    try {

      // configure & start the server
      debugWebsocket = new DebugWebsocketConfiguration()
        .port(9090)
        .startServer();

      // block
      debugWebsocket.waitForShutdown();

    } finally {
      if(debugWebsocket != null) {
        debugWebsocket.shutdown();
      }
    }

  }
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
protected static ProcessEngine createProcessEngine(javax.sql.DataSource datasource, Properties properties) {

    ProcessEngineConfigurationImpl processEngineConfiguration = new StandaloneProcessEngineConfiguration();
    processEngineConfiguration.setDataSource(datasource);
    processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);

    processEngineConfiguration.setHistory(properties.getProperty("historyLevel"));

    processEngineConfiguration.setJdbcBatchProcessing(Boolean.valueOf(properties.getProperty("jdbcBatchProcessing")));

    // load plugins
    String processEnginePlugins = properties.getProperty("processEnginePlugins", "");
    for (String pluginName : processEnginePlugins.split(",")) {
      if(pluginName.length() > 1) {
        Object pluginInstance = ReflectUtil.instantiate(pluginName);
        if(!(pluginInstance instanceof ProcessEnginePlugin)) {
          throw new PerfTestException("Plugin "+pluginName +" is not an instance of ProcessEnginePlugin");

        } else {
          List<ProcessEnginePlugin> plugins = processEngineConfiguration.getProcessEnginePlugins();
          if(plugins == null) {
            plugins = new ArrayList<ProcessEnginePlugin>();
            processEngineConfiguration.setProcessEnginePlugins(plugins);
          }
          plugins.add((ProcessEnginePlugin) pluginInstance);

        }
      }
    }

    return processEngineConfiguration.buildProcessEngine();
  }
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(name = "spinProcessEnginePlugin")
public static ProcessEnginePlugin spinProcessEnginePlugin() {
  return new SpinProcessEnginePlugin();
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(name = "connectProcessEnginePlugin")
public static ProcessEnginePlugin connectProcessEnginePlugin() {
  return new ConnectProcessEnginePlugin();
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
public ProcessEnginePlugin beforeStandardConfiguration() {
  return new BeforeStandardConfiguration();
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
public ProcessEnginePlugin afterStandardConfiguration() {
  return new AfterStandardConfiguration();
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
private List<ProcessEnginePlugin> createUnordedList() {
  List<ProcessEnginePlugin> list = new ArrayList<ProcessEnginePlugin>();
  list.add(mock(ProcessEnginePlugin.class));
  list.add(mock(ProcessEnginePlugin.class));
  return list;
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
public FluentProcessEngineConfiguration addProcessEnginePlugin(ProcessEnginePlugin plugin) {
  processEngineConfiguration.getProcessEnginePlugins().add(plugin);
  return this;
}
 

import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
public void register(final ProcessEnginePlugin processEnginePlugin) {

    eventBus.on(Selectors.type(PreInitEvent.class), (Consumer<PreInitEvent>) event -> processEnginePlugin.preInit(event.getData()));

    eventBus.on(Selectors.type(PostInitEvent.class), (Consumer<PostInitEvent>) event -> processEnginePlugin.postInit(event.getData()));

    eventBus.on(Selectors.type(PostProcessEngineBuild.class), (Consumer<PostProcessEngineBuild>) event -> processEnginePlugin.postProcessEngineBuild(event.getData()));
  }