Class AsyncHistoryManager
- java.lang.Object
-
- org.flowable.engine.impl.persistence.AbstractManager
-
- org.flowable.engine.impl.history.AbstractHistoryManager
-
- org.flowable.engine.impl.history.async.AbstractAsyncHistoryManager
-
- org.flowable.engine.impl.history.async.AsyncHistoryManager
-
- All Implemented Interfaces:
HistoryManager
public class AsyncHistoryManager extends AbstractAsyncHistoryManager
-
-
Field Summary
-
Fields inherited from class org.flowable.engine.impl.persistence.AbstractManager
processEngineConfiguration
-
-
Constructor Summary
Constructors Constructor Description AsyncHistoryManager(ProcessEngineConfigurationImpl processEngineConfiguration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcreateHistoricActivityInstance(ActivityInstance activityInstance)Create new historic activity instance from runtime activity instancevoiddeleteHistoryUserTaskLog(long logNumber)Delete historic user task log entryprotected com.fasterxml.jackson.databind.node.ObjectNodegetActivityStart(String runtimeActivityInstanceId, boolean removeFromAsyncHistorySession)protected com.fasterxml.jackson.databind.node.ObjectNodegetActivityStart(String executionId, String activityId, boolean removeFromAsyncHistorySession)AsyncHistorySessiongetAsyncHistorySession()protected JobServiceConfigurationgetJobServiceConfiguration()protected voidhandleTaskAssigneeChange(TaskEntity taskEntity, String activityInstanceId, Date changeTime)protected voidhandleTaskOwnerChange(TaskEntity taskEntity, String activityInstanceId, Date changeTime)voidrecordActivityEnd(ExecutionEntity executionEntity, String deleteReason, Date endTime)Record activity end in the case when runtime activity instance does not exist.voidrecordActivityEnd(ActivityInstance activityInstance)Record the end of an activity, if activity history is enabled.voidrecordActivityStart(ActivityInstance activityInstance)Record the start of an activity, if activity history is enabled.voidrecordBulkDeleteProcessInstances(Collection<String> processInstanceIds)Bulk delete historic process instances by idvoidrecordDeleteHistoricProcessInstancesByProcessDefinitionId(String processDefinitionId)Deletes historic process instances for a provided process definition idvoidrecordEntityLinkCreated(EntityLinkEntity entityLink)Record the creation of a newEntityLink, if audit history is enabled.voidrecordEntityLinkDeleted(EntityLinkEntity entityLink)Record the deletion of aEntityLink, if audit history is enabledvoidrecordFormPropertiesSubmitted(ExecutionEntity execution, Map<String,String> properties, String taskId, Date createTime)Report form properties submitted, if audit history is enabled.voidrecordHistoricDetailVariableCreate(VariableInstanceEntity variable, ExecutionEntity sourceActivityExecution, boolean useActivityId, String activityInstanceId, Date createTime)Record a variable has been created, if audit history is enabled.voidrecordHistoricTaskDeleted(org.flowable.task.api.history.HistoricTaskInstance task)Record historic task deleted, if audit history is enabled.voidrecordHistoricUserTaskLogEntry(org.flowable.task.api.history.HistoricTaskLogEntryBuilder taskLogEntryBuilder)Record historic user task log entryvoidrecordIdentityLinkCreated(IdentityLinkEntity identityLink)Record the creation of a newIdentityLink, if audit history is enabled.voidrecordIdentityLinkDeleted(IdentityLinkEntity identityLink)Record the deletion of aIdentityLink, if audit history is enabledvoidrecordProcessDefinitionChange(String processInstanceId, String processDefinitionId)Record a change of the process-definition id of a process instance, if activity history is enabled.voidrecordProcessInstanceDeleted(String processInstanceId, String processDefinitionId, String processTenantId)Deletes a historic process instance and all historic data includedvoidrecordProcessInstanceEnd(ExecutionEntity processInstance, String deleteReason, String activityId, Date endTime)Record a process-instance ended.voidrecordProcessInstanceNameChange(ExecutionEntity processInstanceExecution, String newName)Record a process-instance name change.voidrecordProcessInstanceStart(ExecutionEntity processInstance)Record a process-instance started and record start-event if activity history is enabled.voidrecordTaskCreated(TaskEntity task, ExecutionEntity execution)Record the creation of a task, if audit history is enabled.voidrecordTaskEnd(TaskEntity task, ExecutionEntity execution, String deleteReason, Date endTime)Record task as ended, if audit history is enabled.voidrecordTaskInfoChange(TaskEntity taskEntity, String runtimeActivityInstanceId, Date changeTime)Record task name change, if audit history is enabled.voidrecordVariableCreate(VariableInstanceEntity variable, Date createTime)Record a variable has been created, if audit history is enabled.voidrecordVariableRemoved(VariableInstanceEntity variable)Record a variable has been deleted, if audit history is enabled.voidrecordVariableUpdate(VariableInstanceEntity variable, Date updateTime)Record a variable has been updated, if audit history is enabled.voidupdateHistoricActivityInstance(ActivityInstance activityInstance)Update historic activity instance according to changes done in the runtime activityvoidupdateProcessBusinessKeyInHistory(ExecutionEntity processInstance)voidupdateProcessBusinessStatusInHistory(ExecutionEntity processInstance)voidupdateProcessDefinitionIdInHistory(ProcessDefinitionEntity processDefinitionEntity, ExecutionEntity processInstance)Record the update of a process definition for historic process instance, task, and activity instance, if history is enabled.-
Methods inherited from class org.flowable.engine.impl.history.async.AbstractAsyncHistoryManager
addCommonActivityInstanceFields, addCommonEntityLinkFields, addCommonIdentityLinkFields, addCommonProcessInstanceFields, addCommonTaskFields, addCommonVariableFields, addHistoricTaskLogEntryFields, addProcessDefinitionFields, addProcessDefinitionFields
-
Methods inherited from class org.flowable.engine.impl.history.AbstractHistoryManager
createAttachmentComment, createGroupIdentityLinkComment, createIdentityLinkComment, createIdentityLinkComment, createProcessInstanceIdentityLinkComment, createProcessInstanceIdentityLinkComment, createUserIdentityLinkComment, createUserIdentityLinkComment, findHistoricActivityInstance, findHistoricActivityInstance, getActivityIdForExecution, getEntityCache, getHistoricActivityInstanceFromCache, getHistoryConfigurationSettings, getProcessDefinitionId, isHistoryEnabled, isHistoryEnabled, isHistoryLevelAtLeast, isHistoryLevelAtLeast, parseActivityType, updateActivity
-
Methods inherited from class org.flowable.engine.impl.persistence.AbstractManager
getActivityInstanceEntityManager, getAsyncExecutor, getAttachmentEntityManager, getByteArrayEntityManager, getClock, getCommandContext, getCommandExecutor, getCommentEntityManager, getDeploymentEntityManager, getEventDispatcher, getExecutionEntityManager, getHistoricActivityInstanceEntityManager, getHistoricDetailEntityManager, getHistoricProcessInstanceEntityManager, getHistoryManager, getModelEntityManager, getProcessDefinitionEntityManager, getProcessDefinitionInfoEntityManager, getProcessEngineConfiguration, getResourceEntityManager, getSession
-
-
-
-
Constructor Detail
-
AsyncHistoryManager
public AsyncHistoryManager(ProcessEngineConfigurationImpl processEngineConfiguration)
-
-
Method Detail
-
getAsyncHistorySession
public AsyncHistorySession getAsyncHistorySession()
-
recordProcessInstanceStart
public void recordProcessInstanceStart(ExecutionEntity processInstance)
Description copied from interface:HistoryManagerRecord a process-instance started and record start-event if activity history is enabled.
-
recordProcessInstanceEnd
public void recordProcessInstanceEnd(ExecutionEntity processInstance, String deleteReason, String activityId, Date endTime)
Description copied from interface:HistoryManagerRecord a process-instance ended. Updates the historic process instance if activity history is enabled.
-
recordProcessInstanceNameChange
public void recordProcessInstanceNameChange(ExecutionEntity processInstanceExecution, String newName)
Description copied from interface:HistoryManagerRecord a process-instance name change.
-
recordProcessInstanceDeleted
public void recordProcessInstanceDeleted(String processInstanceId, String processDefinitionId, String processTenantId)
Description copied from interface:HistoryManagerDeletes a historic process instance and all historic data included
-
recordDeleteHistoricProcessInstancesByProcessDefinitionId
public void recordDeleteHistoricProcessInstancesByProcessDefinitionId(String processDefinitionId)
Description copied from interface:HistoryManagerDeletes historic process instances for a provided process definition id
-
recordBulkDeleteProcessInstances
public void recordBulkDeleteProcessInstances(Collection<String> processInstanceIds)
Description copied from interface:HistoryManagerBulk delete historic process instances by id
-
recordActivityStart
public void recordActivityStart(ActivityInstance activityInstance)
Description copied from interface:HistoryManagerRecord the start of an activity, if activity history is enabled.- Parameters:
activityInstance- activity instance template
-
recordActivityEnd
public void recordActivityEnd(ExecutionEntity executionEntity, String deleteReason, Date endTime)
Description copied from interface:HistoryManagerRecord activity end in the case when runtime activity instance does not exist.
-
recordActivityEnd
public void recordActivityEnd(ActivityInstance activityInstance)
Description copied from interface:HistoryManagerRecord the end of an activity, if activity history is enabled.- Parameters:
activityInstance- activity instance template
-
recordProcessDefinitionChange
public void recordProcessDefinitionChange(String processInstanceId, String processDefinitionId)
Description copied from interface:HistoryManagerRecord a change of the process-definition id of a process instance, if activity history is enabled.
-
recordTaskCreated
public void recordTaskCreated(TaskEntity task, ExecutionEntity execution)
Description copied from interface:HistoryManagerRecord the creation of a task, if audit history is enabled.
-
recordTaskEnd
public void recordTaskEnd(TaskEntity task, ExecutionEntity execution, String deleteReason, Date endTime)
Description copied from interface:HistoryManagerRecord task as ended, if audit history is enabled.
-
recordTaskInfoChange
public void recordTaskInfoChange(TaskEntity taskEntity, String runtimeActivityInstanceId, Date changeTime)
Description copied from interface:HistoryManagerRecord task name change, if audit history is enabled.
-
handleTaskAssigneeChange
protected void handleTaskAssigneeChange(TaskEntity taskEntity, String activityInstanceId, Date changeTime)
-
handleTaskOwnerChange
protected void handleTaskOwnerChange(TaskEntity taskEntity, String activityInstanceId, Date changeTime)
-
recordHistoricTaskDeleted
public void recordHistoricTaskDeleted(org.flowable.task.api.history.HistoricTaskInstance task)
Description copied from interface:HistoryManagerRecord historic task deleted, if audit history is enabled.
-
recordVariableCreate
public void recordVariableCreate(VariableInstanceEntity variable, Date createTime)
Description copied from interface:HistoryManagerRecord a variable has been created, if audit history is enabled.
-
recordHistoricDetailVariableCreate
public void recordHistoricDetailVariableCreate(VariableInstanceEntity variable, ExecutionEntity sourceActivityExecution, boolean useActivityId, String activityInstanceId, Date createTime)
Description copied from interface:HistoryManagerRecord a variable has been created, if audit history is enabled.
-
recordVariableUpdate
public void recordVariableUpdate(VariableInstanceEntity variable, Date updateTime)
Description copied from interface:HistoryManagerRecord a variable has been updated, if audit history is enabled.
-
recordVariableRemoved
public void recordVariableRemoved(VariableInstanceEntity variable)
Description copied from interface:HistoryManagerRecord a variable has been deleted, if audit history is enabled.
-
recordFormPropertiesSubmitted
public void recordFormPropertiesSubmitted(ExecutionEntity execution, Map<String,String> properties, String taskId, Date createTime)
Description copied from interface:HistoryManagerReport form properties submitted, if audit history is enabled.
-
recordIdentityLinkCreated
public void recordIdentityLinkCreated(IdentityLinkEntity identityLink)
Description copied from interface:HistoryManagerRecord the creation of a newIdentityLink, if audit history is enabled.
-
recordIdentityLinkDeleted
public void recordIdentityLinkDeleted(IdentityLinkEntity identityLink)
Description copied from interface:HistoryManagerRecord the deletion of aIdentityLink, if audit history is enabled
-
recordEntityLinkCreated
public void recordEntityLinkCreated(EntityLinkEntity entityLink)
Description copied from interface:HistoryManagerRecord the creation of a newEntityLink, if audit history is enabled.
-
recordEntityLinkDeleted
public void recordEntityLinkDeleted(EntityLinkEntity entityLink)
Description copied from interface:HistoryManagerRecord the deletion of aEntityLink, if audit history is enabled
-
updateProcessBusinessKeyInHistory
public void updateProcessBusinessKeyInHistory(ExecutionEntity processInstance)
-
updateProcessBusinessStatusInHistory
public void updateProcessBusinessStatusInHistory(ExecutionEntity processInstance)
-
updateProcessDefinitionIdInHistory
public void updateProcessDefinitionIdInHistory(ProcessDefinitionEntity processDefinitionEntity, ExecutionEntity processInstance)
Description copied from interface:HistoryManagerRecord the update of a process definition for historic process instance, task, and activity instance, if history is enabled.
-
updateHistoricActivityInstance
public void updateHistoricActivityInstance(ActivityInstance activityInstance)
Description copied from interface:HistoryManagerUpdate historic activity instance according to changes done in the runtime activity
-
createHistoricActivityInstance
public void createHistoricActivityInstance(ActivityInstance activityInstance)
Description copied from interface:HistoryManagerCreate new historic activity instance from runtime activity instance- Parameters:
activityInstance- activity instance template
-
recordHistoricUserTaskLogEntry
public void recordHistoricUserTaskLogEntry(org.flowable.task.api.history.HistoricTaskLogEntryBuilder taskLogEntryBuilder)
Description copied from interface:HistoryManagerRecord historic user task log entry- Parameters:
taskLogEntryBuilder- historic user task log entry description
-
deleteHistoryUserTaskLog
public void deleteHistoryUserTaskLog(long logNumber)
Description copied from interface:HistoryManagerDelete historic user task log entry- Parameters:
logNumber- log identifier
-
getActivityStart
protected com.fasterxml.jackson.databind.node.ObjectNode getActivityStart(String executionId, String activityId, boolean removeFromAsyncHistorySession)
-
getActivityStart
protected com.fasterxml.jackson.databind.node.ObjectNode getActivityStart(String runtimeActivityInstanceId, boolean removeFromAsyncHistorySession)
-
getJobServiceConfiguration
protected JobServiceConfiguration getJobServiceConfiguration()
-
-