org.camunda.bpm.engine.RepositoryService.updateProcessDefinitionSuspensionState()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(15.8k)|赞(0)|评价(0)|浏览(101)

本文整理了Java中org.camunda.bpm.engine.RepositoryService.updateProcessDefinitionSuspensionState方法的一些代码示例，展示了RepositoryService.updateProcessDefinitionSuspensionState的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RepositoryService.updateProcessDefinitionSuspensionState方法的具体详情如下：
包路径：org.camunda.bpm.engine.RepositoryService
类名称：RepositoryService
方法名：updateProcessDefinitionSuspensionState

RepositoryService.updateProcessDefinitionSuspensionState介绍

[英]Activate or suspend process definitions using a fluent builder. Specify the definitions by calling one of the by methods, like byProcessDefinitionId. To update the suspension state call UpdateProcessDefinitionSuspensionStateBuilder#activate() or UpdateProcessDefinitionSuspensionStateBuilder#suspend().
[中]使用fluent builder激活或挂起流程定义。通过调用by方法之一指定定义，如byProcessDefinitionId。要更新暂停状态，请调用UpdateProcessDefinitionSuspendionStateBuilder#activate（）或UpdateProcessDefinitionSuspendionStateBuilder#suspend（）。

代码示例

代码示例来源：origin: camunda/camunda-bpm-platform

protected void scheduleProcessDefinitionActivation(CommandContext commandContext, DeploymentEntity deployment) {
 if (deploymentBuilder.getProcessDefinitionsActivationDate() != null) {
  RepositoryService repositoryService = commandContext.getProcessEngineConfiguration().getRepositoryService();
  for (ProcessDefinition processDefinition: deployment.getDeployedProcessDefinitions()) {
   // If activation date is set, we first suspend all the process definition
   repositoryService
    .updateProcessDefinitionSuspensionState()
    .byProcessDefinitionId(processDefinition.getId())
    .suspend();
   // And we schedule an activation at the provided date
   repositoryService
    .updateProcessDefinitionSuspensionState()
    .byProcessDefinitionId(processDefinition.getId())
    .executionDate(deploymentBuilder.getProcessDefinitionsActivationDate())
    .activate();
  }
 }
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void activateProcessDefinitionIncludingJobDefinitionsForAllTenants() {
 // given suspended jobs
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .suspend();
 JobDefinitionQuery query = engineRule.getManagementService().createJobDefinitionQuery();
 assertThat(query.active().count(), is(0L));
 assertThat(query.suspended().count(), is(3L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .activate();
 assertThat(query.suspended().count(), is(0L));
 assertThat(query.active().count(), is(3L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionIncludingJobDefinitionsForAllTenants() {
 // given activated jobs
 JobDefinitionQuery query = engineRule.getManagementService().createJobDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .suspend();
 assertThat(query.active().count(), is(0L));
 assertThat(query.suspended().count(), is(3L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void activateProcessDefinitionForNonTenant() {
 // given suspend process definitions
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .suspend();
 ProcessDefinitionQuery query = engineRule.getRepositoryService().createProcessDefinitionQuery();
 assertThat(query.suspended().count(), is(3L));
 assertThat(query.active().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionWithoutTenantId()
  .activate();
 assertThat(query.suspended().count(), is(2L));
 assertThat(query.active().count(), is(1L));
 assertThat(query.active().withoutTenantId().count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void activateProcessDefinitionIncludingJobDefinitionsForTenant() {
 // given suspended jobs
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .suspend();
 JobDefinitionQuery query = engineRule.getManagementService().createJobDefinitionQuery();
 assertThat(query.active().count(), is(0L));
 assertThat(query.suspended().count(), is(3L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionTenantId(TENANT_ONE)
  .activate();
 assertThat(query.suspended().count(), is(2L));
 assertThat(query.active().count(), is(1L));
 assertThat(query.active().tenantIdIn(TENANT_ONE).count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void activateProcessDefinitionIncludingJobDefinitionsForNonTenant() {
 // given suspended jobs
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .suspend();
 JobDefinitionQuery query = engineRule.getManagementService().createJobDefinitionQuery();
 assertThat(query.active().count(), is(0L));
 assertThat(query.suspended().count(), is(3L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionWithoutTenantId()
  .activate();
 assertThat(query.suspended().count(), is(2L));
 assertThat(query.active().count(), is(1L));
 assertThat(query.active().withoutTenantId().count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionForTenant() {
 // given activated process definitions
 ProcessDefinitionQuery query = engineRule.getRepositoryService().createProcessDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionTenantId(TENANT_ONE)
  .suspend();
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().tenantIdIn(TENANT_ONE).count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionIncludingJobDefinitionsForNonTenant() {
 // given activated jobs
 JobDefinitionQuery query = engineRule.getManagementService().createJobDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionWithoutTenantId()
  .suspend();
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().withoutTenantId().count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionForNonTenant() {
 // given activated process definitions
 ProcessDefinitionQuery query = engineRule.getRepositoryService().createProcessDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionWithoutTenantId()
  .suspend();
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().withoutTenantId().count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionIncludeInstancesForNonTenant() {
 // given activated process instances
 ProcessInstanceQuery query = engineRule.getRuntimeService().createProcessInstanceQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionWithoutTenantId()
  .includeProcessInstances(true)
  .suspend();
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().withoutTenantId().count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionIncludingJobDefinitionsForTenant() {
 // given activated jobs
 JobDefinitionQuery query = engineRule.getManagementService().createJobDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionTenantId(TENANT_ONE)
  .suspend();
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().tenantIdIn(TENANT_ONE).count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionIncludeInstancesForTenant() {
 // given activated process instances
 ProcessInstanceQuery query = engineRule.getRuntimeService().createProcessInstanceQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionTenantId(TENANT_ONE)
  .includeProcessInstances(true)
  .suspend();
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().tenantIdIn(TENANT_ONE).count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionNoAuthenticatedTenants() {
 // given activated process definitions
 ProcessDefinitionQuery query = engineRule.getRepositoryService().createProcessDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 engineRule.getIdentityService().setAuthentication("user", null, null);
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .suspend();
 engineRule.getIdentityService().clearAuthentication();
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().withoutTenantId().count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void delayedSuspendProcessDefinitionsForAllTenants() {
 // given activated process definitions
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .executionDate(tomorrow())
  .suspend();
 ProcessDefinitionQuery query = engineRule.getRepositoryService().createProcessDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 // when execute the job to suspend the process definitions
 Job job = engineRule.getManagementService().createJobQuery().timers().singleResult();
 assertThat(job, is(notNullValue()));
 engineRule.getManagementService().executeJob(job.getId());
 assertThat(query.active().count(), is(0L));
 assertThat(query.suspended().count(), is(3L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void suspendProcessDefinitionDisabledTenantCheck() {
 // given activated process definitions
 ProcessDefinitionQuery query = engineRule.getRepositoryService().createProcessDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 ProcessEngineConfigurationImpl processEngineConfiguration = engineRule.getProcessEngineConfiguration();
 processEngineConfiguration.setTenantCheckEnabled(false);
 engineRule.getIdentityService().setAuthentication("user", null, null);
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .suspend();
 assertThat(query.active().count(), is(0L));
 assertThat(query.suspended().count(), is(3L));
 assertThat(query.suspended().tenantIdIn(TENANT_ONE, TENANT_TWO).includeProcessDefinitionsWithoutTenantId().count(), is(3L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void delayedSuspendProcessDefinitionsForNonTenant() {
 // given activated process definitions
 engineRule.getRepositoryService()
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(PROCESS_DEFINITION_KEY)
  .processDefinitionWithoutTenantId()
  .executionDate(tomorrow())
  .suspend();
 ProcessDefinitionQuery query = engineRule.getRepositoryService().createProcessDefinitionQuery();
 assertThat(query.active().count(), is(3L));
 assertThat(query.suspended().count(), is(0L));
 // when execute the job to suspend the process definition
 Job job = engineRule.getManagementService().createJobQuery().timers().singleResult();
 assertThat(job, is(notNullValue()));
 engineRule.getManagementService().executeJob(job.getId());
 assertThat(query.active().count(), is(2L));
 assertThat(query.suspended().count(), is(1L));
 assertThat(query.suspended().withoutTenantId().count(), is(1L));
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/runtime/oneTaskProcess.bpmn20.xml"})
public void testDelayedSuspendProcessDefinitionUsingBuilder() {
 ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 // suspend process definition in one week from now
 long oneWeekFromStartTime = new Date().getTime() + (7 * 24 * 60 * 60 * 1000);
 repositoryService
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionId(processDefinition.getId())
  .executionDate(new Date(oneWeekFromStartTime))
  .suspend();
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertFalse(processDefinition.isSuspended());
 // execute the suspension job
 Job job = managementService.createJobQuery().singleResult();
 assertNotNull(job);
 managementService.executeJob(job.getId());
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertTrue(processDefinition.isSuspended());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/repository/processOne.bpmn20.xml"})
public void testSuspendAndActivateProcessDefinitionByIdUsingBuilder() {
 ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertFalse(processDefinition.isSuspended());
 // suspend
 repositoryService
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionId(processDefinition.getId())
  .suspend();
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertTrue(processDefinition.isSuspended());
 // activate
 repositoryService
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionId(processDefinition.getId())
  .activate();
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertFalse(processDefinition.isSuspended());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/repository/processOne.bpmn20.xml"})
public void testSuspendAndActivateProcessDefinitionByKeyUsingBuilder() {
 ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertFalse(processDefinition.isSuspended());
 // suspend
 repositoryService
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(processDefinition.getKey())
  .suspend();
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertTrue(processDefinition.isSuspended());
 // activate
 repositoryService
  .updateProcessDefinitionSuspensionState()
  .byProcessDefinitionKey(processDefinition.getKey())
  .activate();
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertFalse(processDefinition.isSuspended());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void failToSuspendProcessDefinitionByIdNoAuthenticatedTenants() {
 ProcessDefinition processDefinition = engineRule.getRepositoryService().createProcessDefinitionQuery()
   .processDefinitionKey(PROCESS_DEFINITION_KEY).tenantIdIn(TENANT_ONE).singleResult();
 // declare expected exception
 thrown.expect(ProcessEngineException.class);
 thrown.expectMessage("Cannot update the process definition '"+ processDefinition.getId() 
  + "' because it belongs to no authenticated tenant");
 engineRule.getIdentityService().setAuthentication("user", null, null);
 engineRule.getRepositoryService()
   .updateProcessDefinitionSuspensionState()
   .byProcessDefinitionId(processDefinition.getId())
   .suspend();
}

内容来源于网络，如有侵权，请联系作者删除！

RepositoryService

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    RepositoryService类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com