本文整理了Java中org.camunda.bpm.engine.RepositoryService.updateCaseDefinitionHistoryTimeToLive
方法的一些代码示例,展示了RepositoryService.updateCaseDefinitionHistoryTimeToLive
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RepositoryService.updateCaseDefinitionHistoryTimeToLive
方法的具体详情如下:
包路径:org.camunda.bpm.engine.RepositoryService
类名称:RepositoryService
方法名:updateCaseDefinitionHistoryTimeToLive
[英]Updates time to live of case definition. The field is used within history cleanup process.
[中]更新案例定义的生存时间。该字段在历史清理过程中使用。
代码示例来源:origin: camunda/camunda-bpm-platform
@Override
public void updateHistoryTimeToLive(HistoryTimeToLiveDto historyTimeToLiveDto) {
engine.getRepositoryService().updateCaseDefinitionHistoryTimeToLive(caseDefinitionId, historyTimeToLiveDto.getHistoryTimeToLive());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Override
public void updateHistoryTimeToLive(HistoryTimeToLiveDto historyTimeToLiveDto) {
engine.getRepositoryService().updateCaseDefinitionHistoryTimeToLive(caseDefinitionId, historyTimeToLiveDto.getHistoryTimeToLive());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Test
public void updateHistoryTimeToLiveWithAuthenticatedTenant() {
identityService.setAuthentication("user", null, Arrays.asList(TENANT_ONE));
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitionId, 6);
CaseDefinition definition = repositoryService.getCaseDefinition(caseDefinitionId);
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)
.updateCaseDefinitionHistoryTimeToLive(eq(MockProvider.EXAMPLE_CASE_DEFINITION_ID), eq(-1));
given()
.pathParam("id", MockProvider.EXAMPLE_CASE_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(UPDATE_HISTORY_TIME_TO_LIVE_URL);
verify(repositoryServiceMock).updateCaseDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_CASE_DEFINITION_ID, -1);
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Test
public void testUpdateHistoryTimeToLiveAuthorizationException() {
String expectedMessage = "expectedMessage";
doThrow(new AuthorizationException(expectedMessage))
.when(repositoryServiceMock)
.updateCaseDefinitionHistoryTimeToLive(eq(MockProvider.EXAMPLE_CASE_DEFINITION_ID), eq(5));
given()
.pathParam("id", MockProvider.EXAMPLE_CASE_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(UPDATE_HISTORY_TIME_TO_LIVE_URL);
verify(repositoryServiceMock).updateCaseDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_CASE_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 case definition");
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitionId, 6);
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources={"org/camunda/bpm/engine/test/api/cmmn/oneTaskCase.cmmn"})
public void testUpdateHistoryTimeToLive() {
// given
// there exists a deployment containing a case definition with key "oneTaskCase"
CaseDefinition caseDefinition = findOnlyCaseDefinition();
// when
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinition.getId(), 6);
// then
caseDefinition = findOnlyCaseDefinition();
assertEquals(6, caseDefinition.getHistoryTimeToLive().intValue());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Test
public void updateHistoryTimeToLiveDisabledTenantCheck() {
processEngineConfiguration.setTenantCheckEnabled(false);
identityService.setAuthentication("user", null, null);
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitionId, 6);
CaseDefinition definition = repositoryService.getCaseDefinition(caseDefinitionId);
assertThat(definition.getTenantId(), is(TENANT_ONE));
assertThat(definition.getHistoryTimeToLive(), is(6));
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources={"org/camunda/bpm/engine/test/api/cmmn/oneTaskCase.cmmn"})
public void testUpdateHistoryTimeToLiveNegative() {
// given
// there exists a deployment containing a case definition with key "oneTaskCase"
CaseDefinition caseDefinition = findOnlyCaseDefinition();
// when
try {
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinition.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
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
@Deployment(resources={"org/camunda/bpm/engine/test/api/cmmn/oneTaskCase.cmmn"})
public void testUpdateHistoryTimeToLiveNull() {
// given
// there exists a deployment containing a case definition with key "oneTaskCase"
CaseDefinition caseDefinition = findOnlyCaseDefinition();
// when
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinition.getId(), null);
// then
caseDefinition = findOnlyCaseDefinition();
assertEquals(null, caseDefinition.getHistoryTimeToLive());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Test
public void testUpdateHistoryTimeToLive() {
given()
.pathParam("id", MockProvider.EXAMPLE_CASE_DEFINITION_ID)
.content(new HistoryTimeToLiveDto(5))
.contentType(ContentType.JSON)
.then()
.expect()
.statusCode(Status.NO_CONTENT.getStatusCode())
.when()
.put(UPDATE_HISTORY_TIME_TO_LIVE_URL);
verify(repositoryServiceMock).updateCaseDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_CASE_DEFINITION_ID, 5);
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Test
public void testUpdateHistoryTimeToLiveNullValue() {
given()
.pathParam("id", MockProvider.EXAMPLE_CASE_DEFINITION_ID)
.content(new HistoryTimeToLiveDto())
.contentType(ContentType.JSON)
.then()
.expect()
.statusCode(Status.NO_CONTENT.getStatusCode())
.when()
.put(UPDATE_HISTORY_TIME_TO_LIVE_URL);
verify(repositoryServiceMock).updateCaseDefinitionHistoryTimeToLive(MockProvider.EXAMPLE_CASE_DEFINITION_ID, null);
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources={"org/camunda/bpm/engine/test/api/cmmn/oneTaskCase.cmmn"})
public void testUpdateHistoryTimeToLiveInCache() {
// given
// there exists a deployment containing a case definition with key "oneTaskCase"
CaseDefinition caseDefinition = findOnlyCaseDefinition();
// assume
assertNull(caseDefinition.getHistoryTimeToLive());
// when
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinition.getId(), 10);
CaseDefinition definition = repositoryService.getCaseDefinition(caseDefinition.getId());
assertEquals(Integer.valueOf(10), definition.getHistoryTimeToLive());
}
代码示例来源:origin: camunda/camunda-bpm-platform
private void prepareCaseInstances(String key, int daysInThePast, Integer historyTimeToLive, int instanceCount) {
// update time to live
List<CaseDefinition> caseDefinitions = repositoryService.createCaseDefinitionQuery().caseDefinitionKey(key).list();
assertEquals(1, caseDefinitions.size());
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitions.get(0).getId(), historyTimeToLive);
Date oldCurrentTime = ClockUtil.getCurrentTime();
ClockUtil.setCurrentTime(DateUtils.addDays(oldCurrentTime, daysInThePast));
for (int i = 0; i < instanceCount; i++) {
CaseInstance caseInstance = caseService.createCaseInstanceByKey(key);
caseService.terminateCaseExecution(caseInstance.getId());
caseService.closeCaseInstance(caseInstance.getId());
}
ClockUtil.setCurrentTime(oldCurrentTime);
}
代码示例来源:origin: camunda/camunda-bpm-platform
private void prepareCaseInstances(String key, int daysInThePast, Integer historyTimeToLive, int instanceCount, String tenantId) {
// update time to live
List<CaseDefinition> caseDefinitions = null;
if (tenantId != null) {
caseDefinitions = repositoryService.createCaseDefinitionQuery().caseDefinitionKey(key).tenantIdIn(tenantId).list();
} else {
caseDefinitions = repositoryService.createCaseDefinitionQuery().caseDefinitionKey(key).withoutTenantId().list();
}
assertEquals(1, caseDefinitions.size());
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitions.get(0).getId(), historyTimeToLive);
Date oldCurrentTime = ClockUtil.getCurrentTime();
ClockUtil.setCurrentTime(DateUtils.addDays(new Date(), daysInThePast));
for (int i = 0; i < instanceCount; i++) {
CaseInstance caseInstance = caseService.createCaseInstanceById(caseDefinitions.get(0).getId());
if (tenantId != null) {
assertEquals(tenantId, caseInstance.getTenantId());
}
caseService.terminateCaseExecution(caseInstance.getId());
caseService.closeCaseInstance(caseInstance.getId());
}
ClockUtil.setCurrentTime(oldCurrentTime);
}
代码示例来源:origin: camunda/camunda-bpm-platform
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitions.get(0).getId(), caseTimeToLive);
代码示例来源:origin: camunda/camunda-bpm-platform
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitions.get(0).getId(), caseTimeToLive);
代码示例来源:origin: org.camunda.bpm/camunda-engine
@Test
public void updateHistoryTimeToLiveWithAuthenticatedTenant() {
identityService.setAuthentication("user", null, Arrays.asList(TENANT_ONE));
repositoryService.updateCaseDefinitionHistoryTimeToLive(caseDefinitionId, 6);
CaseDefinition definition = repositoryService.getCaseDefinition(caseDefinitionId);
assertThat(definition.getTenantId(), is(TENANT_ONE));
assertThat(definition.getHistoryTimeToLive(), is(6));
}
代码示例来源:origin: org.camunda.bpm/camunda-engine
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);
}
内容来源于网络,如有侵权,请联系作者删除!