diff --git a/modules/activiti-engine/src/main/java/org/activiti/engine/ProcessEngineConfiguration.java b/modules/activiti-engine/src/main/java/org/activiti/engine/ProcessEngineConfiguration.java index c4cc51083574d37939064bdbfc686d63a31b77f9..787f3f6390b926519da13ee550a68d5e1f689cb0 100644 --- a/modules/activiti-engine/src/main/java/org/activiti/engine/ProcessEngineConfiguration.java +++ b/modules/activiti-engine/src/main/java/org/activiti/engine/ProcessEngineConfiguration.java @@ -96,7 +96,7 @@ public abstract class ProcessEngineConfiguration implements EngineServices { public static final String NO_TENANT_ID = ""; protected String processEngineName = ProcessEngines.NAME_DEFAULT; - protected int idBlockSize = 100; + protected int idBlockSize = 2500; protected String history = HistoryLevel.AUDIT.getKey(); protected boolean jobExecutorActivate; diff --git a/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/RestResponseFactory.java b/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/RestResponseFactory.java index 7c7488dfd901eabd8f72184fc7774b861243c4f7..023b457b0516067d1fc17b8da0ef513b49aa01ee 100644 --- a/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/RestResponseFactory.java +++ b/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/RestResponseFactory.java @@ -59,10 +59,10 @@ import org.activiti.rest.service.api.engine.variable.IntegerRestVariableConverte import org.activiti.rest.service.api.engine.variable.LongRestVariableConverter; import org.activiti.rest.service.api.engine.variable.QueryVariable; import org.activiti.rest.service.api.engine.variable.RestVariable; +import org.activiti.rest.service.api.engine.variable.RestVariable.RestVariableScope; import org.activiti.rest.service.api.engine.variable.RestVariableConverter; import org.activiti.rest.service.api.engine.variable.ShortRestVariableConverter; import org.activiti.rest.service.api.engine.variable.StringRestVariableConverter; -import org.activiti.rest.service.api.engine.variable.RestVariable.RestVariableScope; import org.activiti.rest.service.api.form.FormDataResponse; import org.activiti.rest.service.api.form.RestEnumFormProperty; import org.activiti.rest.service.api.form.RestFormProperty; @@ -79,10 +79,10 @@ import org.activiti.rest.service.api.identity.UserResponse; import org.activiti.rest.service.api.management.JobResponse; import org.activiti.rest.service.api.management.TableResponse; import org.activiti.rest.service.api.repository.DeploymentResourceResponse; +import org.activiti.rest.service.api.repository.DeploymentResourceResponse.DeploymentResourceType; import org.activiti.rest.service.api.repository.DeploymentResponse; import org.activiti.rest.service.api.repository.ModelResponse; import org.activiti.rest.service.api.repository.ProcessDefinitionResponse; -import org.activiti.rest.service.api.repository.DeploymentResourceResponse.DeploymentResourceType; import org.activiti.rest.service.api.runtime.process.ExecutionResponse; import org.activiti.rest.service.api.runtime.process.ProcessInstanceResponse; import org.activiti.rest.service.api.runtime.task.TaskResponse; @@ -430,6 +430,7 @@ public class RestResponseFactory { result.setId(processInstance.getId()); result.setProcessDefinitionId(processInstance.getProcessDefinitionId()); result.setProcessDefinitionUrl(securedResource.createFullResourceUrl(RestUrls.URL_PROCESS_DEFINITION, processInstance.getProcessDefinitionId())); + result.setEnded(processInstance.isEnded()); result.setSuspended(processInstance.isSuspended()); result.setUrl(securedResource.createFullResourceUrl(RestUrls.URL_PROCESS_INSTANCE, processInstance.getId())); result.setTenantId(processInstance.getTenantId()); diff --git a/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResource.java b/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResource.java index 7e9516d11e2beddb0c0df7ce1f974c4364aac176..fba63633535c293c8a3b3b09f6ac89f075b088fe 100644 --- a/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResource.java +++ b/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResource.java @@ -87,7 +87,7 @@ public class ProcessInstanceResource extends SecuredResource { } ActivitiUtil.getRuntimeService().suspendProcessInstanceById(processInstance.getId()); - ProcessInstanceResponse response = getApplication(ActivitiRestServicesApplication.class).getRestResponseFactory() + ProcessInstanceResponse response = getApplication(ActivitiRestServicesApplication.class).getRestResponseFactory() .createProcessInstanceResponse(this, processInstance); // No need to re-fetch the instance, just alter the suspended state of the result-object diff --git a/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResponse.java b/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResponse.java index 843522da976346f35b6ba7e571505c8c311ede7f..7dc13bc5a445e35f5140b607d450dd8b78036a73 100644 --- a/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResponse.java +++ b/modules/activiti-rest/src/main/java/org/activiti/rest/service/api/runtime/process/ProcessInstanceResponse.java @@ -26,6 +26,7 @@ public class ProcessInstanceResponse { protected String url; protected String businessKey; protected boolean suspended; + protected boolean ended; protected String processDefinitionId; protected String processDefinitionUrl; protected String activityId; @@ -64,6 +65,14 @@ public class ProcessInstanceResponse { this.suspended = suspended; } + public boolean isEnded() { + return ended; + } + + public void setEnded(boolean ended) { + this.ended = ended; + } + public String getProcessDefinitionId() { return processDefinitionId; } diff --git a/modules/activiti-rest/src/test/java/org/activiti/rest/service/api/runtime/ProcessInstanceCollectionResourceTest.java b/modules/activiti-rest/src/test/java/org/activiti/rest/service/api/runtime/ProcessInstanceCollectionResourceTest.java index bd3a08a08e35281024291126546c23a1e2217aa9..a769ac57d59efdfcab58b9d7533782bcf17d651e 100644 --- a/modules/activiti-rest/src/test/java/org/activiti/rest/service/api/runtime/ProcessInstanceCollectionResourceTest.java +++ b/modules/activiti-rest/src/test/java/org/activiti/rest/service/api/runtime/ProcessInstanceCollectionResourceTest.java @@ -298,6 +298,11 @@ public class ProcessInstanceCollectionResourceTest extends BaseRestTestCase { client.post(requestNode); assertEquals(Status.SUCCESS_CREATED, client.getResponse().getStatus()); + + JsonNode responseNode = objectMapper.readTree(client.getResponseEntity().getStream()); + assertEquals("processTask", responseNode.get("activityId").asText()); + assertEquals(false, responseNode.get("ended").asBoolean()); + ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().singleResult(); assertNotNull(processInstance);