public class ExternalTaskEntity extends Object implements ExternalTask, DbEntity, HasDbRevision, HasDbReferences
Constructor and Description |
---|
ExternalTaskEntity() |
Modifier and Type | Method and Description |
---|---|
boolean |
areRetriesLeft() |
void |
bpmnError(String errorCode,
String errorMessage,
Map<String,Object> variables) |
void |
complete(Map<String,Object> variables,
Map<String,Object> localVariables) |
static ExternalTaskEntity |
createAndInsert(ExecutionEntity execution,
String topic,
long priority) |
protected void |
createIncident() |
protected IncidentContext |
createIncidentContext() |
void |
delete() |
protected void |
deleteFromExecutionAndRuntimeTable(boolean incidentResolved) |
protected void |
ensureActive() |
protected void |
ensureErrorByteArrayInitialized() |
protected void |
ensureExecutionInitialized(boolean validateExistence) |
protected void |
ensureVariablesSet(ExecutionEntity execution,
Map<String,Object> variables,
Map<String,Object> localVariables) |
protected boolean |
errorEventDefinitionMatches(CamundaErrorEventDefinition camundaErrorEventDefinition,
boolean continueOnException) |
protected boolean |
evaluateThrowBpmnError(ExecutionEntity execution,
boolean continueOnException) |
void |
extendLock(long newLockExpirationTime) |
void |
failed(String errorMessage,
String errorDetails,
int retries,
long retryDuration,
Map<String,Object> variables,
Map<String,Object> localVariables)
process failed state, make sure that binary entity is created for the errorMessage, shortError
message does not exceed limit, handle properly retry counts and incidents
|
String |
getActivityId() |
String |
getActivityInstanceId() |
String |
getBusinessKey()
Returns the business key of the process instance the external task belongs to
|
protected ByteArrayEntity |
getErrorByteArray() |
String |
getErrorDetails()
Method implementation relies on the command context object,
therefore should be invoked from the commands only
|
String |
getErrorDetailsByteArrayId() |
String |
getErrorMessage() |
ExecutionEntity |
getExecution() |
ExecutionEntity |
getExecution(boolean validateExistence) |
String |
getExecutionId() |
Map<String,String> |
getExtensionProperties()
Returns a map containing all custom extension properties of the external task.
|
String |
getId() |
String |
getLastFailureLogId() |
Date |
getLockExpirationTime() |
Object |
getPersistentState()
Returns a representation of the object,
as would be stored in the database.
|
long |
getPriority()
Returns the priority of the external task.
|
String |
getProcessDefinitionId() |
String |
getProcessDefinitionKey() |
String |
getProcessDefinitionVersionTag() |
String |
getProcessInstanceId() |
Map<String,Class> |
getReferencedEntitiesIdAndClass()
Scope: IN-MEMORY references
|
Set<String> |
getReferencedEntityIds()
Scope: IN-MEMORY references
|
Integer |
getRetries() |
int |
getRevision() |
int |
getRevisionNext() |
int |
getSuspensionState() |
String |
getTenantId() |
String |
getTopicName() |
String |
getWorkerId() |
void |
insert() |
boolean |
isSuspended() |
void |
lock(String workerId,
long lockDuration) |
protected void |
produceHistoricExternalTaskCreatedEvent() |
protected void |
produceHistoricExternalTaskDeletedEvent() |
protected void |
produceHistoricExternalTaskFailedEvent() |
protected void |
produceHistoricExternalTaskSuccessfulEvent() |
protected void |
removeIncidents(boolean incidentResolved) |
void |
setActivityId(String activityId) |
void |
setActivityInstanceId(String activityInstanceId) |
void |
setBusinessKey(String businessKey) |
protected void |
setErrorDetails(String exception) |
void |
setErrorMessage(String errorMessage) |
void |
setExecution(ExecutionEntity execution) |
void |
setExecutionId(String executionId) |
void |
setExtensionProperties(Map<String,String> extensionProperties) |
void |
setId(String id) |
void |
setLastFailureLogId(String lastFailureLogId) |
void |
setLockExpirationTime(Date lockExpirationTime) |
void |
setPriority(long priority) |
void |
setProcessDefinitionId(String processDefinitionId) |
void |
setProcessDefinitionKey(String processDefinitionKey) |
void |
setProcessDefinitionVersionTag(String processDefinitionVersionTag) |
void |
setProcessInstanceId(String processInstanceId) |
void |
setRetries(Integer retries) |
void |
setRetriesAndManageIncidents(int retries) |
void |
setRevision(int revision) |
void |
setSuspensionState(int suspensionState) |
void |
setTenantId(String tenantId) |
void |
setTopicName(String topic) |
void |
setWorkerId(String workerId) |
String |
toString() |
void |
unlock() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getDependentEntities
protected static final EnginePersistenceLogger LOG
public static final int MAX_EXCEPTION_MESSAGE_LENGTH
String.length()
counts Unicode supplementary
characters twice, so for a String consisting only of those,
the limit is effectively MAX_EXCEPTION_MESSAGE_LENGTH / 2protected String id
protected int revision
protected String topicName
protected String workerId
protected Date lockExpirationTime
protected Integer retries
protected String errorMessage
protected ByteArrayEntity errorDetailsByteArray
protected String errorDetailsByteArrayId
protected int suspensionState
protected String executionId
protected String processInstanceId
protected String processDefinitionId
protected String processDefinitionKey
protected String processDefinitionVersionTag
protected String activityId
protected String activityInstanceId
protected String tenantId
protected long priority
protected ExecutionEntity execution
protected String businessKey
protected String lastFailureLogId
public String getId()
getId
in interface ExternalTask
getId
in interface DbEntity
public String getTopicName()
getTopicName
in interface ExternalTask
public void setTopicName(String topic)
public String getWorkerId()
getWorkerId
in interface ExternalTask
public void setWorkerId(String workerId)
public Date getLockExpirationTime()
getLockExpirationTime
in interface ExternalTask
public void setLockExpirationTime(Date lockExpirationTime)
public String getExecutionId()
getExecutionId
in interface ExternalTask
public void setExecutionId(String executionId)
public String getProcessDefinitionKey()
getProcessDefinitionKey
in interface ExternalTask
public void setProcessDefinitionKey(String processDefinitionKey)
public String getProcessDefinitionVersionTag()
getProcessDefinitionVersionTag
in interface ExternalTask
public void setProcessDefinitionVersionTag(String processDefinitionVersionTag)
public String getActivityId()
getActivityId
in interface ExternalTask
public void setActivityId(String activityId)
public String getActivityInstanceId()
getActivityInstanceId
in interface ExternalTask
public void setActivityInstanceId(String activityInstanceId)
public int getRevision()
getRevision
in interface HasDbRevision
public void setRevision(int revision)
setRevision
in interface HasDbRevision
public int getRevisionNext()
getRevisionNext
in interface HasDbRevision
public int getSuspensionState()
public void setSuspensionState(int suspensionState)
public boolean isSuspended()
isSuspended
in interface ExternalTask
public String getProcessInstanceId()
getProcessInstanceId
in interface ExternalTask
public void setProcessInstanceId(String processInstanceId)
public String getProcessDefinitionId()
getProcessDefinitionId
in interface ExternalTask
public void setProcessDefinitionId(String processDefinitionId)
public String getTenantId()
getTenantId
in interface ExternalTask
null
if the task belongs to no single tenant.public void setTenantId(String tenantId)
public Integer getRetries()
getRetries
in interface ExternalTask
null
.public void setRetries(Integer retries)
public String getErrorMessage()
getErrorMessage
in interface ExternalTask
null
if no failure was reported previously or if no error message
was submittedTo get the full error details,
use {@link ExternalTaskService#getExternalTaskErrorDetails(String)}
public boolean areRetriesLeft()
public long getPriority()
ExternalTask
getPriority
in interface ExternalTask
public void setPriority(long priority)
public String getBusinessKey()
ExternalTask
getBusinessKey
in interface ExternalTask
public void setBusinessKey(String businessKey)
public Map<String,String> getExtensionProperties()
ExternalTask
getExtensionProperties
in interface ExternalTask
null
public Object getPersistentState()
DbEntity
getPersistentState
in interface DbEntity
public void insert()
public String getErrorDetails()
public void setErrorMessage(String errorMessage)
protected void setErrorDetails(String exception)
public String getErrorDetailsByteArrayId()
protected ByteArrayEntity getErrorByteArray()
protected void ensureErrorByteArrayInitialized()
public void delete()
protected void deleteFromExecutionAndRuntimeTable(boolean incidentResolved)
protected void removeIncidents(boolean incidentResolved)
public void failed(String errorMessage, String errorDetails, int retries, long retryDuration, Map<String,Object> variables, Map<String,Object> localVariables)
errorMessage
- - short error message texterrorDetails
- - full error detailsretries
- - updated value of retries leftretryDuration
- - used for lockExpirationTime calculationpublic void bpmnError(String errorCode, String errorMessage, Map<String,Object> variables)
public void setRetriesAndManageIncidents(int retries)
protected void createIncident()
protected IncidentContext createIncidentContext()
public void lock(String workerId, long lockDuration)
public ExecutionEntity getExecution()
public ExecutionEntity getExecution(boolean validateExistence)
public void setExecution(ExecutionEntity execution)
protected void ensureExecutionInitialized(boolean validateExistence)
protected void ensureActive()
protected void ensureVariablesSet(ExecutionEntity execution, Map<String,Object> variables, Map<String,Object> localVariables)
protected boolean evaluateThrowBpmnError(ExecutionEntity execution, boolean continueOnException)
protected boolean errorEventDefinitionMatches(CamundaErrorEventDefinition camundaErrorEventDefinition, boolean continueOnException)
public void unlock()
public static ExternalTaskEntity createAndInsert(ExecutionEntity execution, String topic, long priority)
protected void produceHistoricExternalTaskCreatedEvent()
protected void produceHistoricExternalTaskFailedEvent()
protected void produceHistoricExternalTaskSuccessfulEvent()
protected void produceHistoricExternalTaskDeletedEvent()
public void extendLock(long newLockExpirationTime)
public Set<String> getReferencedEntityIds()
HasDbReferences
Scope: IN-MEMORY references
getReferencedEntityIds
in interface HasDbReferences
public Map<String,Class> getReferencedEntitiesIdAndClass()
HasDbReferences
Scope: IN-MEMORY references
getReferencedEntitiesIdAndClass
in interface HasDbReferences
public String getLastFailureLogId()
public void setLastFailureLogId(String lastFailureLogId)
Copyright © 2022. All rights reserved.