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

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

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

RepositoryService.updateProcessDefinitionHistoryTimeToLive介绍

[英]Updates time to live of process definition. The field is used within history cleanup process.
[中]更新进程定义的生存时间。该字段在历史清理过程中使用。

代码示例

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

@Override
public void updateHistoryTimeToLive(HistoryTimeToLiveDto historyTimeToLiveDto) {
 engine.getRepositoryService().updateProcessDefinitionHistoryTimeToLive(processDefinitionId, historyTimeToLiveDto.getHistoryTimeToLive());
}

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

@Override
public void updateHistoryTimeToLive(HistoryTimeToLiveDto historyTimeToLiveDto) {
 engine.getRepositoryService().updateProcessDefinitionHistoryTimeToLive(processDefinitionId, historyTimeToLiveDto.getHistoryTimeToLive());
}

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

@Test
public void updateHistoryTimeToLiveWithAuthenticatedTenant() {
 identityService.setAuthentication("user", null, Arrays.asList(TENANT_ONE));
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinitionId, 6);
 ProcessDefinition definition = repositoryService.getProcessDefinition(processDefinitionId);
 assertThat(definition.getTenantId(), is(TENANT_ONE));
 assertThat(definition.getHistoryTimeToLive(), is(6));
}

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

@Test
public void testUpdateHistoryTimeToLiveNegativeValue() {
 String expectedMessage = "expectedMessage";
 doThrow(new BadUserRequestException(expectedMessage))
   .when(repositoryServiceMock)
   .updateProcessDefinitionHistoryTimeToLive(eq(MockProvider.EXAMPLE_PROCESS_DEFINITION_ID), eq(-1));
 given()
   .pathParam("id", MockProvider.EXAMPLE_PROCESS_DEFINITION_ID)
   .content(new HistoryTimeToLiveDto(-1))
   .contentType(ContentType.JSON)
   .then().expect()
    .statusCode(Status.BAD_REQUEST.getStatusCode())
    .body("type", is(BadUserRequestException.class.getSimpleName()))
    .body("message", containsString(expectedMessage))
   .when()
    .put(SINGLE_PROCESS_DEFINITION_HISTORY_TIMETOLIVE_URL);
 verify(repositoryServiceMock).updateProcessDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_PROCESS_DEFINITION_ID, -1);
}

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

@Test
public void testUpdateHistoryTimeToLiveAuthorizationException() {
 String expectedMessage = "expectedMessage";
 doThrow(new AuthorizationException(expectedMessage))
   .when(repositoryServiceMock)
   .updateProcessDefinitionHistoryTimeToLive(eq(MockProvider.EXAMPLE_PROCESS_DEFINITION_ID), eq(5));
 given()
   .pathParam("id", MockProvider.EXAMPLE_PROCESS_DEFINITION_ID)
   .content(new HistoryTimeToLiveDto(5))
   .contentType(ContentType.JSON)
   .then().expect()
   .statusCode(Status.FORBIDDEN.getStatusCode())
   .body("type", is(AuthorizationException.class.getSimpleName()))
   .body("message", containsString(expectedMessage))
   .when()
   .put(SINGLE_PROCESS_DEFINITION_HISTORY_TIMETOLIVE_URL);
 verify(repositoryServiceMock).updateProcessDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_PROCESS_DEFINITION_ID, 5);
}

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

@Test
public void updateHistoryTimeToLiveNoAuthenticatedTenants() {
 identityService.setAuthentication("user", null, null);
 // declare expected exception
 thrown.expect(ProcessEngineException.class);
 thrown.expectMessage("Cannot update the process definition");
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinitionId, 6);
}

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

@Deployment(resources = { "org/camunda/bpm/engine/test/api/oneTaskProcess.bpmn20.xml"})
public void testProcessDefinitionUpdateTimeToLiveNegative() {
 //given
 ProcessDefinition processDefinition = findOnlyProcessDefinition();
 //when
 try {
  repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinition.getId(), -1);
  fail("Exception is expected, that negative value is not allowed.");
 } catch (BadUserRequestException ex) {
  assertTrue(ex.getMessage().contains("greater than"));
 }
}

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

@Deployment(resources = { "org/camunda/bpm/engine/test/api/oneTaskProcess.bpmn20.xml"})
public void testProcessDefinitionUpdateTimeToLive() {
 //given
 ProcessDefinition processDefinition = findOnlyProcessDefinition();
 //when
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinition.getId(), 6);
 //then
 processDefinition = findOnlyProcessDefinition();
 assertEquals(6, processDefinition.getHistoryTimeToLive().intValue());
}

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

@Test
public void updateHistoryTimeToLiveDisabledTenantCheck() {
 processEngineConfiguration.setTenantCheckEnabled(false);
 identityService.setAuthentication("user", null, null);
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinitionId, 6);
 ProcessDefinition definition = repositoryService.getProcessDefinition(processDefinitionId);
 assertThat(definition.getTenantId(), is(TENANT_ONE));
 assertThat(definition.getHistoryTimeToLive(), is(6));
}

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

public void testProcessDefinitionUpdateTimeToLive() {
 // given
 createGrantAuthorization(PROCESS_DEFINITION, ONE_TASK_PROCESS_KEY, userId, UPDATE);
 ProcessDefinition definition = selectProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 // when
 repositoryService.updateProcessDefinitionHistoryTimeToLive(definition.getId(), 6);
 // then
 definition = selectProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 assertEquals(6, definition.getHistoryTimeToLive().intValue());
}

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

private void prepareHistoricProcesses(int instanceCount) {
 Date oldCurrentTime = ClockUtil.getCurrentTime();
 List<String> processInstanceIds = new ArrayList<String>();
 ClockUtil.setCurrentTime(DateUtils.addDays(new Date(), -6));
 for (int i = 0; i < instanceCount; i++) {
  ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("oneTaskProcess");
  processInstanceIds.add(processInstance.getId());
 }
 List<ProcessDefinition> processDefinitions = engineRule.getRepositoryService().createProcessDefinitionQuery().list();
 assertEquals(1, processDefinitions.size());
 engineRule.getRepositoryService().updateProcessDefinitionHistoryTimeToLive(processDefinitions.get(0).getId(), 5);
 runtimeService.deleteProcessInstances(processInstanceIds, null, true, true);
 ClockUtil.setCurrentTime(oldCurrentTime);
}

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

private void removeHistoryTimeToLive() {
 List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery().processDefinitionKey(ONE_TASK_PROCESS).list();
 assertEquals(1, processDefinitions.size());
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinitions.get(0).getId(), null);
 final List<DecisionDefinition> decisionDefinitions = repositoryService.createDecisionDefinitionQuery().decisionDefinitionKey(DECISION).list();
 assertEquals(1, decisionDefinitions.size());
 repositoryService.updateDecisionDefinitionHistoryTimeToLive(decisionDefinitions.get(0).getId(), null);
 final List<CaseDefinition> caseDefinitions = repositoryService.createCaseDefinitionQuery().caseDefinitionKey(ONE_TASK_CASE).list();
 assertEquals(1, caseDefinitions.size());
 repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitions.get(0).getId(), null);
}

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

protected void prepareProcessInstances(String key, int daysInThePast, Integer historyTimeToLive, int instanceCount) {
 List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery().processDefinitionKey(key).list();
 assertEquals(1, processDefinitions.size());
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinitions.get(0).getId(), historyTimeToLive);
 Date oldCurrentTime = ClockUtil.getCurrentTime();
 ClockUtil.setCurrentTime(DateUtils.addDays(oldCurrentTime, daysInThePast));
 List<String> processInstanceIds = new ArrayList<String>();
 for (int i = 0; i < instanceCount; i++) {
  ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(key);
  processInstanceIds.add(processInstance.getId());
 }
 runtimeService.deleteProcessInstances(processInstanceIds, null, true, true);
 ClockUtil.setCurrentTime(oldCurrentTime);
}

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

@Deployment(resources = { "org/camunda/bpm/engine/test/api/oneTaskProcess.bpmn20.xml"})
public void testProcessDefinitionUpdateTimeToLiveNull() {
 //given
 ProcessDefinition processDefinition = findOnlyProcessDefinition();
 //when
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinition.getId(), null);
 //then
 processDefinition = findOnlyProcessDefinition();
 assertEquals(null, processDefinition.getHistoryTimeToLive());
}

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

@Test
public void testUpdateHistoryTimeToLive() {
 given()
   .pathParam("id", MockProvider.EXAMPLE_PROCESS_DEFINITION_ID)
   .content(new HistoryTimeToLiveDto(5))
   .contentType(ContentType.JSON)
   .then().expect()
    .statusCode(Status.NO_CONTENT.getStatusCode())
   .when()
    .put(SINGLE_PROCESS_DEFINITION_HISTORY_TIMETOLIVE_URL);
 verify(repositoryServiceMock).updateProcessDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_PROCESS_DEFINITION_ID, 5);
}

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

@Test
public void testUpdateHistoryTimeToLiveNullValue() {
 given()
   .pathParam("id", MockProvider.EXAMPLE_PROCESS_DEFINITION_ID)
   .content(new HistoryTimeToLiveDto())
   .contentType(ContentType.JSON)
   .then().expect()
    .statusCode(Status.NO_CONTENT.getStatusCode())
   .when()
    .put(SINGLE_PROCESS_DEFINITION_HISTORY_TIMETOLIVE_URL);
 verify(repositoryServiceMock).updateProcessDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_PROCESS_DEFINITION_ID, null);
}

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

protected void prepareProcessInstances(String key, int daysInThePast, Integer historyTimeToLive, int instanceCount) {
 ProcessDefinition processDefinition = selectProcessDefinitionByKey(key);
 disableAuthorization();
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinition.getId(), historyTimeToLive);
 enableAuthorization();
 Date oldCurrentTime = ClockUtil.getCurrentTime();
 ClockUtil.setCurrentTime(DateUtils.addDays(new Date(), daysInThePast));
 List<String> processInstanceIds = new ArrayList<String>();
 for (int i = 0; i < instanceCount; i++) {
  ProcessInstance processInstance = startProcessInstanceByKey(key);
  processInstanceIds.add(processInstance.getId());
 }
 disableAuthorization();
 runtimeService.deleteProcessInstances(processInstanceIds, null, true, true);
 enableAuthorization();
 ClockUtil.setCurrentTime(oldCurrentTime);
}

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

@RequiredHistoryLevel(ProcessEngineConfiguration.HISTORY_FULL)
@Deployment(resources = { "org/camunda/bpm/engine/test/api/oneTaskProcess.bpmn20.xml"})
public void testProcessDefinitionUpdateTimeToLiveUserOperationLog() {
 //given
 ProcessDefinition processDefinition = findOnlyProcessDefinition();
 Integer timeToLiveOrgValue = processDefinition.getHistoryTimeToLive();
 processEngine.getIdentityService().setAuthenticatedUserId("userId");
 //when
 Integer timeToLiveNewValue = 6;
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinition.getId(), timeToLiveNewValue);
 //then
 List<UserOperationLogEntry> opLogEntries = processEngine.getHistoryService().createUserOperationLogQuery().list();
 Assert.assertEquals(1, opLogEntries.size());
 final UserOperationLogEntryEventEntity userOperationLogEntry = (UserOperationLogEntryEventEntity)opLogEntries.get(0);
 assertEquals(UserOperationLogEntry.OPERATION_TYPE_UPDATE_HISTORY_TIME_TO_LIVE, userOperationLogEntry.getOperationType());
 assertEquals(processDefinition.getKey(), userOperationLogEntry.getProcessDefinitionKey());
 assertEquals(processDefinition.getId(), userOperationLogEntry.getProcessDefinitionId());
 assertEquals("historyTimeToLive", userOperationLogEntry.getProperty());
 assertEquals(timeToLiveOrgValue, Integer.valueOf(userOperationLogEntry.getOrgValue()));
 assertEquals(timeToLiveNewValue, Integer.valueOf(userOperationLogEntry.getNewValue()));
}

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

protected void prepareProcessInstances(String key, int daysInThePast, Integer historyTimeToLive, int instanceCount, String tenantId) {
 List<ProcessDefinition> processDefinitions = null;
 if (tenantId == null) {
  processDefinitions = repositoryService.createProcessDefinitionQuery().processDefinitionKey(key).withoutTenantId().list();
 } else {
  processDefinitions = repositoryService.createProcessDefinitionQuery().processDefinitionKey(key).tenantIdIn(tenantId).list();
 }
 assertEquals(1, processDefinitions.size());
 repositoryService.updateProcessDefinitionHistoryTimeToLive(processDefinitions.get(0).getId(), historyTimeToLive);
 Date oldCurrentTime = ClockUtil.getCurrentTime();
 ClockUtil.setCurrentTime(DateUtils.addDays(oldCurrentTime, daysInThePast));
 List<String> processInstanceIds = new ArrayList<String>();
 {
  for (int i = 0; i < instanceCount; i++) {
   String processInstanceId = null;
   if (tenantId == null) {
    processInstanceId = runtimeService.createProcessInstanceByKey(PROCESS_DEFINITION_KEY).processDefinitionWithoutTenantId().execute().getId();
   } else {
    processInstanceId = runtimeService.createProcessInstanceByKey(PROCESS_DEFINITION_KEY).processDefinitionTenantId(tenantId).execute().getId();
   }
   processInstanceIds.add(processInstanceId);
  }
 }
 runtimeService.deleteProcessInstances(processInstanceIds, null, true, true);
 ClockUtil.setCurrentTime(oldCurrentTime);
}

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

public void testDecisionDefinitionUpdateTimeToLiveWithoutAuthorizations() {
 //given
 ProcessDefinition definition = selectProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 try {
  //when
  repositoryService.updateProcessDefinitionHistoryTimeToLive(definition.getId(), 6);
  fail("Exception expected");
 } catch (AuthorizationException e) {
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(ONE_TASK_PROCESS_KEY, message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
 }
}

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

RepositoryService

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    RepositoryService类方法

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