public class AsyncIndexingHistoryManager
extends org.flowable.engine.impl.history.async.AbstractAsyncHistoryManager
Modifier and Type | Field and Description |
---|---|
protected List<PlatformIndexedDataEnhancer> |
indexedDataEnhancers |
protected IndexingManagerHelperImpl |
indexHelper |
static String |
TASK_ASSIGNEE_IDENTITY_LINK_ID_PREFIX |
static String |
TASK_OWNER_IDENTITY_LINK_ID_PREFIX |
Constructor and Description |
---|
AsyncIndexingHistoryManager(org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl processEngineConfiguration,
boolean usePrefixId,
IndexManager indexManager,
IndexVariableTypes indexVariableTypes) |
Modifier and Type | Method and Description |
---|---|
protected void |
addCommonRootProcessInstanceFields(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
addCommonTaskFields(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
org.flowable.engine.impl.persistence.entity.ExecutionEntity execution,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
addCreatedIdentityLink(String id,
String type,
String userId,
String groupId,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
addCreatedUserIdentityLink(String id,
String type,
String userId,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
addProcessDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data,
org.flowable.engine.repository.ProcessDefinition processDefinition,
String key) |
void |
createAttachmentComment(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance,
String attachmentName,
boolean create) |
void |
createHistoricActivityInstance(org.flowable.engine.runtime.ActivityInstance activityInstance) |
void |
createIdentityLinkComment(org.flowable.task.service.impl.persistence.entity.TaskEntity taskEntity,
String userId,
String groupId,
String type,
boolean create,
boolean forceNullUserId) |
void |
createProcessInstanceIdentityLinkComment(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance,
String userId,
String groupId,
String type,
boolean create,
boolean forceNullUserId) |
void |
deleteHistoryUserTaskLog(long logNumber) |
List<PlatformIndexedDataEnhancer> |
getIndexedDataEnhancers() |
protected org.flowable.job.service.JobServiceConfiguration |
getJobServiceConfiguration() |
protected com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingActivityData(String runtimeActivityInstanceId) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingActivityData(String executionId,
String activityId,
String type)
Deprecated.
|
protected com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddActivityData(String activityId,
String tenantId) |
protected void |
handleRecordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
handleRecordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink,
com.fasterxml.jackson.databind.node.ObjectNode data) |
void |
recordActivityEnd(org.flowable.engine.runtime.ActivityInstance activityInstance) |
void |
recordActivityEnd(org.flowable.engine.impl.persistence.entity.ExecutionEntity executionEntity,
String deleteReason,
Date endTime)
Deprecated.
|
void |
recordActivityStart(org.flowable.engine.runtime.ActivityInstance activityInstance) |
void |
recordDeleteHistoricProcessInstancesByProcessDefinitionId(String processDefinitionId) |
void |
recordEntityLinkCreated(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink) |
void |
recordEntityLinkDeleted(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink) |
void |
recordFormPropertiesSubmitted(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance,
Map<String,String> properties,
String taskId,
Date createTime) |
void |
recordHistoricDetailVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
org.flowable.engine.impl.persistence.entity.ExecutionEntity sourceActivityExecution,
boolean useActivityId,
String activityInstanceId,
Date createTime) |
void |
recordHistoricUserTaskLogEntry(org.flowable.task.api.history.HistoricTaskLogEntryBuilder taskLogEntryBuilder) |
void |
recordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink) |
void |
recordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink) |
void |
recordProcessDefinitionChange(String processInstanceId,
String processDefinitionId) |
void |
recordProcessInstanceDeleted(String processInstanceId,
String processDefinitionId,
String tenantId) |
void |
recordProcessInstanceEnd(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance,
String deleteReason,
String activityId,
Date endTime) |
void |
recordProcessInstanceNameChange(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance,
String newName) |
void |
recordProcessInstanceStart(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance) |
protected void |
recordRootProcessInstanceEnd(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance,
String deleteReason,
String activityId,
Date endTime,
Long durationInMillis) |
protected void |
recordRootProcessInstanceNameChange(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance) |
protected void |
recordRootProcessInstanceStart(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance) |
void |
recordTaskCreated(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
org.flowable.engine.impl.persistence.entity.ExecutionEntity execution) |
void |
recordTaskEnd(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
org.flowable.engine.impl.persistence.entity.ExecutionEntity execution,
String deleteReason,
Date endTime) |
void |
recordTaskInfoChange(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
String activityInstanceId,
Date changeTime) |
void |
recordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
Date createTime) |
void |
recordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable) |
void |
recordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
Date updateTime) |
protected void |
removeIdentityLink(com.fasterxml.jackson.databind.node.ObjectNode data,
String id) |
void |
setIndexedDataEnhancers(List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
protected boolean |
shouldIndexActivityInstance(org.flowable.engine.runtime.ActivityInstance activityInstance) |
protected boolean |
shouldIndexIdentityLink(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink) |
void |
updateActivity(org.flowable.engine.impl.persistence.entity.ExecutionEntity executionEntity,
String oldActivityId,
org.flowable.bpmn.model.FlowElement newFlowElement,
org.flowable.task.service.impl.persistence.entity.TaskEntity task,
Date updateTime) |
void |
updateHistoricActivityInstance(org.flowable.engine.runtime.ActivityInstance activityInstance) |
void |
updateProcessBusinessKeyInHistory(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance) |
void |
updateProcessDefinitionIdInHistory(org.flowable.engine.impl.persistence.entity.ProcessDefinitionEntity processDefinitionEntity,
org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance) |
protected void |
updateRootProcessBusinessKeyInHistory(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance) |
addCommonActivityInstanceFields, addCommonEntityLinkFields, addCommonIdentityLinkFields, addCommonProcessInstanceFields, addCommonVariableFields, addHistoricTaskLogEntryFields, addProcessDefinitionFields, addProcessDefinitionFields
createGroupIdentityLinkComment, createIdentityLinkComment, createProcessInstanceIdentityLinkComment, createUserIdentityLinkComment, createUserIdentityLinkComment, findHistoricActivityInstance, findHistoricActivityInstance, getActivityIdForExecution, getEntityCache, getHistoricActivityInstanceFromCache, getHistoryLevel, getProcessDefinitionHistoryLevel, getProcessDefinitionId, getProcessDefinitionId, getProcessDefinitionId, isHistoryEnabled, isHistoryEnabled, isHistoryLevelAtLeast, isHistoryLevelAtLeast, parseActivityType, setHistoryLevel
getActivityInstanceEntityManager, getAsyncExecutor, getAttachmentEntityManager, getByteArrayEntityManager, getClock, getCommandContext, getCommandExecutor, getCommentEntityManager, getDeploymentEntityManager, getEventDispatcher, getExecutionEntityManager, getHistoricActivityInstanceEntityManager, getHistoricDetailEntityManager, getHistoricProcessInstanceEntityManager, getHistoryManager, getModelEntityManager, getProcessDefinitionEntityManager, getProcessDefinitionInfoEntityManager, getProcessEngineConfiguration, getResourceEntityManager, getSession
public static final String TASK_OWNER_IDENTITY_LINK_ID_PREFIX
public static final String TASK_ASSIGNEE_IDENTITY_LINK_ID_PREFIX
protected IndexingManagerHelperImpl indexHelper
protected List<PlatformIndexedDataEnhancer> indexedDataEnhancers
public AsyncIndexingHistoryManager(org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl processEngineConfiguration, boolean usePrefixId, IndexManager indexManager, IndexVariableTypes indexVariableTypes)
protected org.flowable.job.service.JobServiceConfiguration getJobServiceConfiguration()
public void recordProcessInstanceEnd(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance, String deleteReason, String activityId, Date endTime)
protected void recordRootProcessInstanceEnd(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance, String deleteReason, String activityId, Date endTime, Long durationInMillis)
protected void addCommonRootProcessInstanceFields(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance, com.fasterxml.jackson.databind.node.ObjectNode data)
public void recordProcessInstanceStart(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance)
protected void recordRootProcessInstanceStart(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance)
protected void addProcessDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data, org.flowable.engine.repository.ProcessDefinition processDefinition, String key)
public void recordProcessInstanceNameChange(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance, String newName)
protected void recordRootProcessInstanceNameChange(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance)
public void recordProcessInstanceDeleted(String processInstanceId, String processDefinitionId, String tenantId)
public void recordDeleteHistoricProcessInstancesByProcessDefinitionId(String processDefinitionId)
public void recordActivityStart(org.flowable.engine.runtime.ActivityInstance activityInstance)
public void recordActivityEnd(org.flowable.engine.runtime.ActivityInstance activityInstance)
@Deprecated public void recordActivityEnd(org.flowable.engine.impl.persistence.entity.ExecutionEntity executionEntity, String deleteReason, Date endTime)
public void recordProcessDefinitionChange(String processInstanceId, String processDefinitionId)
public void recordTaskCreated(org.flowable.task.service.impl.persistence.entity.TaskEntity task, org.flowable.engine.impl.persistence.entity.ExecutionEntity execution)
public void recordTaskEnd(org.flowable.task.service.impl.persistence.entity.TaskEntity task, org.flowable.engine.impl.persistence.entity.ExecutionEntity execution, String deleteReason, Date endTime)
public void recordTaskInfoChange(org.flowable.task.service.impl.persistence.entity.TaskEntity task, String activityInstanceId, Date changeTime)
public void recordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, Date createTime)
public void recordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, Date updateTime)
public void recordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable)
public void recordHistoricDetailVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, org.flowable.engine.impl.persistence.entity.ExecutionEntity sourceActivityExecution, boolean useActivityId, String activityInstanceId, Date createTime)
public void recordFormPropertiesSubmitted(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance, Map<String,String> properties, String taskId, Date createTime)
public void recordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)
protected void handleRecordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink, com.fasterxml.jackson.databind.node.ObjectNode data)
protected void addCreatedUserIdentityLink(String id, String type, String userId, com.fasterxml.jackson.databind.node.ObjectNode data)
protected void addCreatedIdentityLink(String id, String type, String userId, String groupId, com.fasterxml.jackson.databind.node.ObjectNode data)
public void recordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)
protected void handleRecordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink, com.fasterxml.jackson.databind.node.ObjectNode data)
protected void removeIdentityLink(com.fasterxml.jackson.databind.node.ObjectNode data, String id)
public void recordEntityLinkCreated(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink)
public void recordEntityLinkDeleted(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink)
public void updateProcessBusinessKeyInHistory(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance)
protected void updateRootProcessBusinessKeyInHistory(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance)
public void updateProcessDefinitionIdInHistory(org.flowable.engine.impl.persistence.entity.ProcessDefinitionEntity processDefinitionEntity, org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance)
public void updateHistoricActivityInstance(org.flowable.engine.runtime.ActivityInstance activityInstance)
public void createHistoricActivityInstance(org.flowable.engine.runtime.ActivityInstance activityInstance)
public void recordHistoricUserTaskLogEntry(org.flowable.task.api.history.HistoricTaskLogEntryBuilder taskLogEntryBuilder)
public void deleteHistoryUserTaskLog(long logNumber)
public void createIdentityLinkComment(org.flowable.task.service.impl.persistence.entity.TaskEntity taskEntity, String userId, String groupId, String type, boolean create, boolean forceNullUserId)
createIdentityLinkComment
in interface org.flowable.engine.impl.history.HistoryManager
createIdentityLinkComment
in class org.flowable.engine.impl.history.AbstractHistoryManager
public void createProcessInstanceIdentityLinkComment(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance, String userId, String groupId, String type, boolean create, boolean forceNullUserId)
createProcessInstanceIdentityLinkComment
in interface org.flowable.engine.impl.history.HistoryManager
createProcessInstanceIdentityLinkComment
in class org.flowable.engine.impl.history.AbstractHistoryManager
public void createAttachmentComment(org.flowable.task.service.impl.persistence.entity.TaskEntity task, org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance, String attachmentName, boolean create)
createAttachmentComment
in interface org.flowable.engine.impl.history.HistoryManager
createAttachmentComment
in class org.flowable.engine.impl.history.AbstractHistoryManager
public void updateActivity(org.flowable.engine.impl.persistence.entity.ExecutionEntity executionEntity, String oldActivityId, org.flowable.bpmn.model.FlowElement newFlowElement, org.flowable.task.service.impl.persistence.entity.TaskEntity task, Date updateTime)
updateActivity
in interface org.flowable.engine.impl.history.HistoryManager
updateActivity
in class org.flowable.engine.impl.history.AbstractHistoryManager
protected void addCommonTaskFields(org.flowable.task.service.impl.persistence.entity.TaskEntity task, org.flowable.engine.impl.persistence.entity.ExecutionEntity execution, com.fasterxml.jackson.databind.node.ObjectNode data)
addCommonTaskFields
in class org.flowable.engine.impl.history.async.AbstractAsyncHistoryManager
protected boolean shouldIndexActivityInstance(org.flowable.engine.runtime.ActivityInstance activityInstance)
protected boolean shouldIndexIdentityLink(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)
protected com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddActivityData(String activityId, String tenantId)
protected com.fasterxml.jackson.databind.node.ObjectNode getMatchingActivityData(String runtimeActivityInstanceId)
@Deprecated protected com.fasterxml.jackson.databind.node.ObjectNode getMatchingActivityData(String executionId, String activityId, String type)
public List<PlatformIndexedDataEnhancer> getIndexedDataEnhancers()
public void setIndexedDataEnhancers(List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
Copyright © 2019. All rights reserved.