本文整理汇总了Java中org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin类的典型用法代码示例。如果您正苦于以下问题:Java ProcessEnginePlugin类的具体用法?Java ProcessEnginePlugin怎么用?Java ProcessEnginePlugin使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ProcessEnginePlugin类属于org.camunda.bpm.engine.impl.cfg包,在下文中一共展示了ProcessEnginePlugin类的18个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: processEngineConfiguration
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;
}
开发者ID:IntegrityVision,项目名称:Purchase-order-process-template,代码行数:19,代码来源:Config.java
示例2: eventBus
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."));
}
开发者ID:camunda,项目名称:camunda-bpm-reactor,代码行数:31,代码来源:CamundaReactor.java
示例3: initialize
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);
}
}
}
开发者ID:camunda,项目名称:camunda-bpm-elasticsearch,代码行数:17,代码来源:AbstractElasticSearchTest.java
示例4: createClient
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);
}
}
开发者ID:camunda,项目名称:camunda-bpm-elasticsearch,代码行数:20,代码来源:ElasticSearchClientProvider.java
示例5: configurePlugins
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);
}
}
开发者ID:camunda,项目名称:camunda-bpm-platform,代码行数:20,代码来源:StartProcessEngineStep.java
示例6: spinPluginShouldBeRegistered
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);
}
开发者ID:camunda,项目名称:camunda-bpm-platform,代码行数:17,代码来源:PaSpinSupportTest.java
示例7: processEngineConfigurationImpl
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;
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:10,代码来源:CamundaBpmConfiguration.java
示例8: processEngineConfigurationImplTest
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);
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:10,代码来源:CamundaBpmConfigurationTest.java
示例9: StandaloneInMemoryTestConfiguration
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);
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:9,代码来源:StandaloneInMemoryTestConfiguration.java
示例10: main
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();
}
}
}
开发者ID:camunda,项目名称:camunda-bpm-workbench,代码行数:36,代码来源:StandaloneDebugWebsocketBootstrap.java
示例11: createProcessEngine
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();
}
开发者ID:camunda,项目名称:camunda-bpm-platform,代码行数:33,代码来源:PerfTestProcessEngine.java
示例12: spinProcessEnginePlugin
import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(name = "spinProcessEnginePlugin")
public static ProcessEnginePlugin spinProcessEnginePlugin() {
return new SpinProcessEnginePlugin();
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:6,代码来源:CamundaBpmPluginConfiguration.java
示例13: connectProcessEnginePlugin
import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(name = "connectProcessEnginePlugin")
public static ProcessEnginePlugin connectProcessEnginePlugin() {
return new ConnectProcessEnginePlugin();
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:6,代码来源:CamundaBpmPluginConfiguration.java
示例14: beforeStandardConfiguration
import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
public ProcessEnginePlugin beforeStandardConfiguration() {
return new BeforeStandardConfiguration();
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:5,代码来源:AdditionalCammundaBpmConfigurations.java
示例15: afterStandardConfiguration
import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
@Bean
public ProcessEnginePlugin afterStandardConfiguration() {
return new AfterStandardConfiguration();
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:5,代码来源:AdditionalCammundaBpmConfigurations.java
示例16: createUnordedList
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;
}
开发者ID:camunda,项目名称:camunda-bpm-spring-boot-starter,代码行数:7,代码来源:CamundaBpmConfigurationTest.java
示例17: addProcessEnginePlugin
import org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin; //导入依赖的package包/类
public FluentProcessEngineConfiguration addProcessEnginePlugin(ProcessEnginePlugin plugin) {
processEngineConfiguration.getProcessEnginePlugins().add(plugin);
return this;
}
开发者ID:holisticon,项目名称:skill-based-routing,代码行数:5,代码来源:FluentProcessEngineConfiguration.java
示例18: register
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()));
}
开发者ID:camunda,项目名称:camunda-bpm-reactor,代码行数:9,代码来源:CamundaEventBus.java
注:本文中的org.camunda.bpm.engine.impl.cfg.ProcessEnginePlugin类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论