本文整理了Java中org.activiti.engine.runtime.Job.getExecutionId()
方法的一些代码示例,展示了Job.getExecutionId()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Job.getExecutionId()
方法的具体详情如下:
包路径:org.activiti.engine.runtime.Job
类名称:Job
方法名:getExecutionId
[英]Returns the specific execution on which the job was created.
[中]返回创建作业的特定执行。
代码示例来源:origin: Activiti/Activiti
public Object execute(CommandContext commandContext) {
if (job == null) {
throw new ActivitiIllegalArgumentException("job is null");
}
if (log.isDebugEnabled()) {
log.debug("Executing lock exclusive job {} {}", job.getId(), job.getExecutionId());
}
if (job.isExclusive()) {
if (job.getExecutionId() != null) {
ExecutionEntity execution = commandContext.getExecutionEntityManager().findById(job.getExecutionId());
if (execution != null) {
commandContext.getExecutionEntityManager().updateProcessInstanceLockTime(execution.getProcessInstanceId());
}
}
}
return null;
}
}
代码示例来源:origin: Activiti/Activiti
Object persistedObject = ((ActivitiEntityEvent) event).getEntity();
if (persistedObject instanceof Job) {
event.setExecutionId(((Job) persistedObject).getExecutionId());
event.setProcessInstanceId(((Job) persistedObject).getProcessInstanceId());
event.setProcessDefinitionId(((Job) persistedObject).getProcessDefinitionId());
代码示例来源:origin: org.activiti/activiti-engine
public Object execute(CommandContext commandContext) {
if (job == null) {
throw new ActivitiIllegalArgumentException("job is null");
}
if (log.isDebugEnabled()) {
log.debug("Executing lock exclusive job {} {}", job.getId(), job.getExecutionId());
}
if (job.isExclusive()) {
if (job.getExecutionId() != null) {
ExecutionEntity execution = commandContext.getExecutionEntityManager().findById(job.getExecutionId());
if (execution != null) {
commandContext.getExecutionEntityManager().updateProcessInstanceLockTime(execution.getProcessInstanceId());
}
}
}
return null;
}
}
代码示例来源:origin: org.alfresco/alfresco-repository
private WorkflowTask getTaskForTimer(Job job, ProcessInstance processInstance, Execution jobExecution)
{
if (job instanceof TimerEntity)
{
ReadOnlyProcessDefinition def = activitiUtil.getDeployedProcessDefinition(processInstance.getProcessDefinitionId());
List<String> activeActivityIds = runtimeService.getActiveActivityIds(jobExecution.getId());
if(activeActivityIds.size() == 1)
{
PvmActivity targetActivity = def.findActivity(activeActivityIds.get(0));
if(targetActivity != null)
{
// Only get tasks of active activity is a user-task
String activityType = (String) targetActivity.getProperty(ActivitiConstants.NODE_TYPE);
if(ActivitiConstants.USER_TASK_NODE_TYPE.equals(activityType))
{
Task task = taskService.createTaskQuery().executionId(job.getExecutionId()).singleResult();
return typeConverter.convert(task);
}
}
}
}
return null;
}
代码示例来源:origin: Alfresco/alfresco-repository
private WorkflowTask getTaskForTimer(Job job, ProcessInstance processInstance, Execution jobExecution)
{
if (job instanceof TimerEntity)
{
ReadOnlyProcessDefinition def = activitiUtil.getDeployedProcessDefinition(processInstance.getProcessDefinitionId());
List<String> activeActivityIds = runtimeService.getActiveActivityIds(jobExecution.getId());
if(activeActivityIds.size() == 1)
{
PvmActivity targetActivity = def.findActivity(activeActivityIds.get(0));
if(targetActivity != null)
{
// Only get tasks of active activity is a user-task
String activityType = (String) targetActivity.getProperty(ActivitiConstants.NODE_TYPE);
if(ActivitiConstants.USER_TASK_NODE_TYPE.equals(activityType))
{
Task task = taskService.createTaskQuery().executionId(job.getExecutionId()).singleResult();
return typeConverter.convert(task);
}
}
}
}
return null;
}
代码示例来源:origin: org.alfresco/alfresco-repository
.executionId(job.getExecutionId()).singleResult();
代码示例来源:origin: Alfresco/alfresco-repository
.executionId(job.getExecutionId()).singleResult();
代码示例来源:origin: org.activiti/activiti-rest
public JobResponse createJobResponse(Job job, RestUrlBuilder urlBuilder) {
JobResponse response = new JobResponse();
response.setId(job.getId());
response.setDueDate(job.getDuedate());
response.setExceptionMessage(job.getExceptionMessage());
response.setExecutionId(job.getExecutionId());
response.setProcessDefinitionId(job.getProcessDefinitionId());
response.setProcessInstanceId(job.getProcessInstanceId());
response.setRetries(job.getRetries());
response.setTenantId(job.getTenantId());
response.setUrl(urlBuilder.buildUrl(RestUrls.URL_JOB, job.getId()));
if (job.getProcessDefinitionId() != null) {
response.setProcessDefinitionUrl(urlBuilder.buildUrl(RestUrls.URL_PROCESS_DEFINITION, job.getProcessDefinitionId()));
}
if (job.getProcessInstanceId() != null) {
response.setProcessInstanceUrl(urlBuilder.buildUrl(RestUrls.URL_PROCESS_INSTANCE, job.getProcessInstanceId()));
}
if (job.getExecutionId() != null) {
response.setExecutionUrl(urlBuilder.buildUrl(RestUrls.URL_EXECUTION, job.getExecutionId()));
}
return response;
}
代码示例来源:origin: Alfresco/alfresco-repository
String expectedTimerPathId = BPMEngineRegistry.createGlobalId(ActivitiConstants.ENGINE_ID, timerJob.getExecutionId());
assertNotNull(timer.getPath());
assertEquals(expectedTimerPathId, timer.getPath().getId());
代码示例来源:origin: org.activiti/activiti-engine
Object persistedObject = ((ActivitiEntityEvent) event).getEntity();
if (persistedObject instanceof Job) {
event.setExecutionId(((Job) persistedObject).getExecutionId());
event.setProcessInstanceId(((Job) persistedObject).getProcessInstanceId());
event.setProcessDefinitionId(((Job) persistedObject).getProcessDefinitionId());
内容来源于网络,如有侵权,请联系作者删除!