ExternalTaskEntity (Camunda BPM Javadocs 7.8.14-ee)

java.lang.Object
- org.camunda.bpm.engine.impl.persistence.entity.ExternalTaskEntity

All Implemented Interfaces:: ExternalTask, DbEntity, HasDbReferences, HasDbRevision

public class ExternalTaskEntity
extends Object
implements ExternalTask, DbEntity, HasDbRevision, HasDbReferences

Author:: Thorben Lindhauer, Askar Akhmerov

Field Summary

Fields
Modifier and Type	Field and Description
`protected String`	`activityId`
`protected String`	`activityInstanceId`
`protected ByteArrayEntity`	`errorDetailsByteArray`
`protected String`	`errorDetailsByteArrayId`
`protected String`	`errorMessage`
`protected ExecutionEntity`	`execution`
`protected String`	`executionId`
`protected String`	`id`
`protected Date`	`lockExpirationTime`
`protected static EnginePersistenceLogger`	`LOG`
`static int`	`MAX_EXCEPTION_MESSAGE_LENGTH` Note: `String.length()` counts Unicode supplementary characters twice, so for a String consisting only of those, the limit is effectively MAX_EXCEPTION_MESSAGE_LENGTH / 2
`protected long`	`priority`
`protected String`	`processDefinitionId`
`protected String`	`processDefinitionKey`
`protected String`	`processInstanceId`
`protected Integer`	`retries`
`protected int`	`revision`
`protected int`	`suspensionState`
`protected String`	`tenantId`
`protected String`	`topicName`
`protected String`	`workerId`

Constructor Summary

Constructors
Constructor and Description

ExternalTaskEntity()

Constructors
Constructor and Description
`ExternalTaskEntity()`

Method Summary

Methods
Modifier and Type	Method and Description
`boolean`	`areRetriesLeft()`
`void`	`bpmnError(String errorCode)`
`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()`
`protected void`	`ensureActive()`
`protected void`	`ensureErrorByteArrayInitialized()`
`protected void`	`ensureExecutionInitialized()`
`void`	`extendLock(long newLockExpirationTime)`
`void`	`failed(String errorMessage, String errorDetails, int retries, long retryDuration)` 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()`
`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()`
`String`	`getExecutionId()`
`String`	`getId()`
`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`	`getProcessInstanceId()`
`Map<String,Class>`	`getReferencedEntitiesIdAndClass()`
`Set<String>`	`getReferencedEntityIds()`
`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`	`removeIncident()`
`void`	`setActivityId(String activityId)`
`void`	`setActivityInstanceId(String activityInstanceId)`
`protected void`	`setErrorDetails(String exception)`
`void`	`setErrorMessage(String errorMessage)`
`void`	`setExecution(ExecutionEntity execution)`
`void`	`setExecutionId(String executionId)`
`void`	`setId(String id)`
`void`	`setLockExpirationTime(Date lockExpirationTime)`
`void`	`setPriority(long priority)`
`void`	`setProcessDefinitionId(String processDefinitionId)`
`void`	`setProcessDefinitionKey(String processDefinitionKey)`
`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()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - LOG
```
protected static final EnginePersistenceLogger LOG
```
  - MAX_EXCEPTION_MESSAGE_LENGTH
```
public static final int MAX_EXCEPTION_MESSAGE_LENGTH
```
    Note: String.length() counts Unicode supplementary characters twice, so for a String consisting only of those, the limit is effectively MAX_EXCEPTION_MESSAGE_LENGTH / 2
    
    See Also:
    Constant Field Values
  - id
```
protected String id
```
  - revision
```
protected int revision
```
  - topicName
```
protected String topicName
```
  - workerId
```
protected String workerId
```
  - lockExpirationTime
```
protected Date lockExpirationTime
```
  - retries
```
protected Integer retries
```
  - errorMessage
```
protected String errorMessage
```
  - errorDetailsByteArray
```
protected ByteArrayEntity errorDetailsByteArray
```
  - errorDetailsByteArrayId
```
protected String errorDetailsByteArrayId
```
  - suspensionState
```
protected int suspensionState
```
  - executionId
```
protected String executionId
```
  - processInstanceId
```
protected String processInstanceId
```
  - processDefinitionId
```
protected String processDefinitionId
```
  - processDefinitionKey
```
protected String processDefinitionKey
```
  - activityId
```
protected String activityId
```
  - activityInstanceId
```
protected String activityInstanceId
```
  - tenantId
```
protected String tenantId
```
  - priority
```
protected long priority
```
  - execution
```
protected ExecutionEntity execution
```
- Constructor Detail
  - ExternalTaskEntity
```
public ExternalTaskEntity()
```
- Method Detail
  - getId
```
public String getId()
```
    Specified by:
    
    getId in interface ExternalTask
    
    Specified by:
    
    getId in interface DbEntity
    
    Returns:
    the id of the task
  - setId
```
public void setId(String id)
```
    Specified by:
    
    setId in interface DbEntity
  - getTopicName
```
public String getTopicName()
```
    Specified by:
    
    getTopicName in interface ExternalTask
    
    Returns:
    the name of the topic the task belongs to
  - setTopicName
```
public void setTopicName(String topic)
```
  - getWorkerId
```
public String getWorkerId()
```
    Specified by:
    
    getWorkerId in interface ExternalTask
    
    Returns:
    the id of the worker that has locked the task
  - setWorkerId
```
public void setWorkerId(String workerId)
```
  - getLockExpirationTime
```
public Date getLockExpirationTime()
```
    Specified by:
    
    getLockExpirationTime in interface ExternalTask
    
    Returns:
    the absolute time at which the lock expires
  - setLockExpirationTime
```
public void setLockExpirationTime(Date lockExpirationTime)
```
  - getExecutionId
```
public String getExecutionId()
```
    Specified by:
    
    getExecutionId in interface ExternalTask
    
    Returns:
    the id of the execution that the task is assigned to
  - setExecutionId
```
public void setExecutionId(String executionId)
```
  - getProcessDefinitionKey
```
public String getProcessDefinitionKey()
```
    Specified by:
    
    getProcessDefinitionKey in interface ExternalTask
    
    Returns:
    the key of the process definition the task's activity belongs to
  - setProcessDefinitionKey
```
public void setProcessDefinitionKey(String processDefinitionKey)
```
  - getActivityId
```
public String getActivityId()
```
    Specified by:
    
    getActivityId in interface ExternalTask
    
    Returns:
    the id of the activity for which the task is created
  - setActivityId
```
public void setActivityId(String activityId)
```
  - getActivityInstanceId
```
public String getActivityInstanceId()
```
    Specified by:
    
    getActivityInstanceId in interface ExternalTask
    
    Returns:
    the id of the activity instance in which context the task exists
  - setActivityInstanceId
```
public void setActivityInstanceId(String activityInstanceId)
```
  - getRevision
```
public int getRevision()
```
    Specified by:
    
    getRevision in interface HasDbRevision
  - setRevision
```
public void setRevision(int revision)
```
    Specified by:
    
    setRevision in interface HasDbRevision
  - getRevisionNext
```
public int getRevisionNext()
```
    Specified by:
    
    getRevisionNext in interface HasDbRevision
  - getSuspensionState
```
public int getSuspensionState()
```
  - setSuspensionState
```
public void setSuspensionState(int suspensionState)
```
  - isSuspended
```
public boolean isSuspended()
```
    Specified by:
    
    isSuspended in interface ExternalTask
    
    Returns:
    true if the external task is suspended; a suspended external task cannot be completed, thereby preventing process continuation
  - getProcessInstanceId
```
public String getProcessInstanceId()
```
    Specified by:
    
    getProcessInstanceId in interface ExternalTask
    
    Returns:
    the id of the process instance the task exists in
  - setProcessInstanceId
```
public void setProcessInstanceId(String processInstanceId)
```
  - getProcessDefinitionId
```
public String getProcessDefinitionId()
```
    Specified by:
    
    getProcessDefinitionId in interface ExternalTask
    
    Returns:
    the id of the process definition the task's activity belongs to
  - setProcessDefinitionId
```
public void setProcessDefinitionId(String processDefinitionId)
```
  - getTenantId
```
public String getTenantId()
```
    Specified by:
    
    getTenantId in interface ExternalTask
    
    Returns:
    the id of the tenant the task belongs to. Can be null if the task belongs to no single tenant.
  - setTenantId
```
public void setTenantId(String tenantId)
```
  - getRetries
```
public Integer getRetries()
```
    Specified by:
    
    getRetries in interface ExternalTask
    
    Returns:
    the number of retries left. The number of retries is provided by a task client, therefore the initial value is null.
  - setRetries
```
public void setRetries(Integer retries)
```
  - getErrorMessage
```
public String getErrorMessage()
```
    Specified by:
    
    getErrorMessage in interface ExternalTask
    
    Returns:
    short error message submitted with the latest reported failure executing this task; null if no failure was reported previously or if no error message was submitted
    See Also:
    To get the full error details, use {@link ExternalTaskService#getExternalTaskErrorDetails(String)}
  - areRetriesLeft
```
public boolean areRetriesLeft()
```
  - getPriority
```
public long getPriority()
```
    Description copied from interface: ExternalTask
    
    Returns the priority of the external task.
    
    Specified by:
    
    getPriority in interface ExternalTask
    
    Returns:
    the priority of the external task
  - setPriority
```
public void setPriority(long priority)
```
  - getPersistentState
```
public Object getPersistentState()
```
    Description copied from interface: DbEntity
    
    Returns a representation of the object, as would be stored in the database. Used when deciding if updates have occurred to the object or not since it was last loaded.
    
    Specified by:
    
    getPersistentState in interface DbEntity
  - insert
```
public void insert()
```
  - getErrorDetails
```
public String getErrorDetails()
```
    Method implementation relies on the command context object, therefore should be invoked from the commands only
    
    Returns:
    error details persisted in byte array table
  - setErrorMessage
```
public void setErrorMessage(String errorMessage)
```
  - setErrorDetails
```
protected void setErrorDetails(String exception)
```
  - getErrorDetailsByteArrayId
```
public String getErrorDetailsByteArrayId()
```
  - getErrorByteArray
```
protected ByteArrayEntity getErrorByteArray()
```
  - ensureErrorByteArrayInitialized
```
protected void ensureErrorByteArrayInitialized()
```
  - delete
```
public void delete()
```
  - deleteFromExecutionAndRuntimeTable
```
protected void deleteFromExecutionAndRuntimeTable()
```
  - complete
```
public void complete(Map<String,Object> variables,
            Map<String,Object> localVariables)
```
  - failed
```
public void failed(String errorMessage,
          String errorDetails,
          int retries,
          long retryDuration)
```
    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
    
    Parameters:
    errorMessage - - short error message text
    errorDetails - - full error details
    retries - - updated value of retries left
    retryDuration - - used for lockExpirationTime calculation
  - bpmnError
```
public void bpmnError(String errorCode)
```
  - setRetriesAndManageIncidents
```
public void setRetriesAndManageIncidents(int retries)
```
  - createIncident
```
protected void createIncident()
```
  - removeIncident
```
protected void removeIncident()
```
  - createIncidentContext
```
protected IncidentContext createIncidentContext()
```
  - lock
```
public void lock(String workerId,
        long lockDuration)
```
  - getExecution
```
public ExecutionEntity getExecution()
```
  - setExecution
```
public void setExecution(ExecutionEntity execution)
```
  - ensureExecutionInitialized
```
protected void ensureExecutionInitialized()
```
  - ensureActive
```
protected void ensureActive()
```
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - unlock
```
public void unlock()
```
  - createAndInsert
```
public static ExternalTaskEntity createAndInsert(ExecutionEntity execution,
                                 String topic,
                                 long priority)
```
  - produceHistoricExternalTaskCreatedEvent
```
protected void produceHistoricExternalTaskCreatedEvent()
```
  - produceHistoricExternalTaskFailedEvent
```
protected void produceHistoricExternalTaskFailedEvent()
```
  - produceHistoricExternalTaskSuccessfulEvent
```
protected void produceHistoricExternalTaskSuccessfulEvent()
```
  - produceHistoricExternalTaskDeletedEvent
```
protected void produceHistoricExternalTaskDeletedEvent()
```
  - extendLock
```
public void extendLock(long newLockExpirationTime)
```
  - getReferencedEntityIds
```
public Set<String> getReferencedEntityIds()
```
    Specified by:
    
    getReferencedEntityIds in interface HasDbReferences
    
    Returns:
    the ids of the entities that this entity references. Should only return ids for entities of the same type
  - getReferencedEntitiesIdAndClass
```
public Map<String,Class> getReferencedEntitiesIdAndClass()
```
    Specified by:
    
    getReferencedEntitiesIdAndClass in interface HasDbReferences
    
    Returns:
    a map of the ids and the entities' classes that this entity references. It's used when trying to determine if there was an Optimistic Locking occurrence on an INSERT or UPDATE of an object of this type.

Class ExternalTaskEntity

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

MAX_EXCEPTION_MESSAGE_LENGTH

id

revision

topicName

workerId

lockExpirationTime

retries

errorMessage

errorDetailsByteArray

errorDetailsByteArrayId

suspensionState

executionId

processInstanceId

processDefinitionId

processDefinitionKey

activityId

activityInstanceId

tenantId

priority

execution

Constructor Detail

ExternalTaskEntity

Method Detail

getId

setId

getTopicName

setTopicName

getWorkerId

setWorkerId

getLockExpirationTime

setLockExpirationTime

getExecutionId

setExecutionId

getProcessDefinitionKey

setProcessDefinitionKey

getActivityId

setActivityId

getActivityInstanceId

setActivityInstanceId

getRevision

setRevision

getRevisionNext

getSuspensionState

setSuspensionState

isSuspended

getProcessInstanceId

setProcessInstanceId

getProcessDefinitionId

setProcessDefinitionId

getTenantId

setTenantId

getRetries

setRetries

getErrorMessage

areRetriesLeft

getPriority

setPriority

getPersistentState

insert

getErrorDetails

setErrorMessage

setErrorDetails

getErrorDetailsByteArrayId

getErrorByteArray

ensureErrorByteArrayInitialized

delete

deleteFromExecutionAndRuntimeTable

complete

failed

bpmnError

setRetriesAndManageIncidents

createIncident

removeIncident