org.flowable.compatibility

Class DefaultFlowable5CompatibilityHandler

java.lang.Object

org.flowable.compatibility.DefaultFlowable5CompatibilityHandler

All Implemented Interfaces:

Flowable5CompatibilityHandler

Direct Known Subclasses:

DefaultFlowable5SpringCompatibilityHandler

public class DefaultFlowable5CompatibilityHandler
extends Object
implements Flowable5CompatibilityHandler

Author:

Joram Barrez, Tijs Rademakers

Field Summary

Fields

Modifier and Type	Field and Description
protected ProcessEngineConfiguration	flowable6ProcessEngineConfiguration
protected ProcessEngine	processEngine
protected DefaultProcessEngineFactory	processEngineFactory

Constructor Summary

Constructors

Constructor and Description
DefaultFlowable5CompatibilityHandler()

Method Summary

Modifier and Type	Method and Description
void	activateProcessDefinition(String processDefinitionId, String processDefinitionKey, boolean activateProcessInstances, Date activationDate, String tenantId)
void	activateProcessInstance(String processInstanceId)
void	addCandidateStarter(String processDefinitionId, String userId, String groupId)
Comment	addComment(String taskId, String processInstanceId, String type, String message)
void	addIdentityLink(String taskId, String identityId, int identityIdType, String identityType)
void	addIdentityLinkForProcessInstance(String processInstanceId, String userId, String groupId, String identityLinkType)
protected void	callJobProcessors(JobProcessorContext.Phase processorType, AbstractJobEntity abstractJobEntity, ProcessEngineConfigurationImpl processEngineConfiguration)
void	changeDeploymentTenantId(String deploymentId, String newTenantId)
void	claimTask(String taskId, String userId)
void	completeTask(TaskEntity taskEntity, Map<String,Object> variables, boolean localScope)
void	completeTask(TaskEntity taskEntity, Map<String,Object> variables, Map<String,Object> transientVariables)
protected JobEntity	convertToActiviti5JobEntity(JobEntity job)
protected TaskEntity	convertToActiviti5TaskEntity(TaskEntity task)
Attachment	createAttachment(String attachmentType, String taskId, String processInstanceId, String attachmentName, String attachmentDescription, InputStream content, String url)
void	deleteAttachment(String attachmentId)
void	deleteCandidateStarter(String processDefinitionId, String userId, String groupId)
void	deleteComment(String commentId, String taskId, String processInstanceId)
void	deleteDeployment(String deploymentId, boolean cascade)
void	deleteHistoricProcessInstance(String processInstanceId)
void	deleteHistoricTask(String taskId)
void	deleteIdentityLink(String taskId, String userId, String groupId, String identityLinkType)
void	deleteIdentityLinkForProcessInstance(String processInstanceId, String userId, String groupId, String identityLinkType)
void	deleteJob(String jobId)
void	deleteProcessInstance(String processInstanceId, String deleteReason)
void	deleteTask(String taskId, String deleteReason, boolean cascade)
Deployment	deploy(DeploymentBuilderImpl activiti6DeploymentBuilder)
void	executeJob(Job job)
void	executeJobWithLockAndRetry(Job job)
Object	getCamelContextObject(String camelContextValue)
Object	getExecutionVariable(String executionId, String variableName, boolean isLocal)
VariableInstance	getExecutionVariableInstance(String executionId, String variableName, boolean isLocal)
Map<String,VariableInstance>	getExecutionVariableInstances(String executionId, Collection<String> variableNames, boolean isLocal)
Map<String,Object>	getExecutionVariables(String executionId, Collection<String> variableNames, boolean isLocal)
ProcessEngineConfiguration	getFlowable6ProcessEngineConfiguration()
String	getFormKey(String processDefinitionId, String taskDefinitionKey)
ProcessDefinition	getProcessDefinition(String processDefinitionId)
BpmnModel	getProcessDefinitionBpmnModel(String processDefinitionId)
ProcessDefinition	getProcessDefinitionByKey(String processDefinitionKey)
com.fasterxml.jackson.databind.node.ObjectNode	getProcessDefinitionInfo(String processDefinitionId)
Process	getProcessDefinitionProcessObject(String processDefinitionId)
protected ProcessEngine	getProcessEngine()
DefaultProcessEngineFactory	getProcessEngineFactory()
ProcessInstance	getProcessInstance(String processInstanceId)
Object	getRawCommandExecutor()
Object	getRawProcessConfiguration()
Object	getRawProcessEngine()
Object	getRenderedStartForm(String processDefinitionId, String formEngineName)
Object	getScriptingEngineValue(String payloadExpressionValue, String languageValue, DelegateExecution execution)
StartFormData	getStartFormData(String processDefinitionId)
TaskFormData	getTaskFormData(String taskId)
Map<String,Object>	getVariables(ProcessInstance processInstance)
protected void	handleActivitiException(ActivitiException e)
void	handleFailedJob(Job job, Throwable exception)
boolean	isProcessDefinitionSuspended(String processDefinitionId)
void	leaveExecution(DelegateExecution execution)
boolean	mapException(Exception camelException, DelegateExecution execution, List<MapExceptionEntry> mapExceptions)
void	messageEventReceived(String messageName, String executionId, Map<String,Object> processVariables, boolean async)
void	propagateError(BpmnError bpmnError, DelegateExecution execution)
void	removeExecutionVariables(String executionId, Collection<String> variableNames, boolean isLocal)
void	removeTaskVariables(String taskId, Collection<String> variableNames, boolean isLocal)
void	resetClock()
ProcessDefinitionCacheEntry	resolveProcessDefinition(ProcessDefinition processDefinition)
void	saveAttachment(Attachment attachment)
void	saveTask(TaskEntity task)
void	setClock(Clock clock)
void	setDeploymentCategory(String deploymentId, String category)
void	setExecutionVariables(String executionId, Map<String,? extends Object> variables, boolean isLocal)
void	setFlowable6ProcessEngineConfiguration(ProcessEngineConfiguration flowable6ProcessEngineConfiguration)
void	setJobProcessor(List<Object> flowable5JobProcessors)
void	setProcessDefinitionCategory(String processDefinitionId, String category)
void	setProcessEngineFactory(DefaultProcessEngineFactory processEngineFactory)
void	setProcessInstanceName(String processInstanceId, String processInstanceName)
void	setTaskDueDate(String taskId, Date dueDate)
void	setTaskPriority(String taskId, int priority)
void	setTaskVariables(String taskId, Map<String,? extends Object> variables, boolean isLocal)
void	signalEventReceived(SignalEventSubscriptionEntity signalEventSubscriptionEntity, Object payload, boolean async)
void	signalEventReceived(String signalName, String executionId, Map<String,Object> processVariables, boolean async, String tenantId)
ProcessInstance	startProcessInstance(String processDefinitionKey, String processDefinitionId, Map<String,Object> variables, Map<String,Object> transientVariables, String businessKey, String tenantId, String processInstanceName)
ProcessInstance	startProcessInstanceByMessage(String messageName, Map<String,Object> variables, Map<String,Object> transientVariables, String businessKey, String tenantId)
ProcessInstance	submitStartFormData(String processDefinitionId, String businessKey, Map<String,String> properties)
void	submitTaskFormData(String taskId, Map<String,String> properties, boolean completeTask)
void	suspendProcessDefinition(String processDefinitionId, String processDefinitionKey, boolean suspendProcessInstances, Date suspensionDate, String tenantId)
void	suspendProcessInstance(String processInstanceId)
void	throwErrorEvent(FlowableEvent event)
void	trigger(String executionId, Map<String,Object> processVariables, Map<String,Object> transientVariables)
void	updateBusinessKey(String processInstanceId, String businessKey)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

processEngineFactory

protected DefaultProcessEngineFactory processEngineFactory

processEngine

protected volatile ProcessEngine processEngine

flowable6ProcessEngineConfiguration

protected volatile ProcessEngineConfiguration flowable6ProcessEngineConfiguration

Constructor Detail

DefaultFlowable5CompatibilityHandler

public DefaultFlowable5CompatibilityHandler()

Method Detail

getProcessDefinition

public ProcessDefinition getProcessDefinition(String processDefinitionId)

Specified by:

getProcessDefinition in interface Flowable5CompatibilityHandler

getProcessDefinitionByKey

public ProcessDefinition getProcessDefinitionByKey(String processDefinitionKey)

Specified by:

getProcessDefinitionByKey in interface Flowable5CompatibilityHandler

getProcessDefinitionProcessObject

public Process getProcessDefinitionProcessObject(String processDefinitionId)

Specified by:

getProcessDefinitionProcessObject in interface Flowable5CompatibilityHandler

getProcessDefinitionBpmnModel

public BpmnModel getProcessDefinitionBpmnModel(String processDefinitionId)

Specified by:

getProcessDefinitionBpmnModel in interface Flowable5CompatibilityHandler

addCandidateStarter

public void addCandidateStarter(String processDefinitionId,
                                String userId,
                                String groupId)

Specified by:

addCandidateStarter in interface Flowable5CompatibilityHandler

getProcessDefinitionInfo

public com.fasterxml.jackson.databind.node.ObjectNode getProcessDefinitionInfo(String processDefinitionId)

Specified by:

getProcessDefinitionInfo in interface Flowable5CompatibilityHandler

resolveProcessDefinition

public ProcessDefinitionCacheEntry resolveProcessDefinition(ProcessDefinition processDefinition)

Specified by:

resolveProcessDefinition in interface Flowable5CompatibilityHandler

isProcessDefinitionSuspended

public boolean isProcessDefinitionSuspended(String processDefinitionId)

Specified by:

isProcessDefinitionSuspended in interface Flowable5CompatibilityHandler

deleteCandidateStarter

public void deleteCandidateStarter(String processDefinitionId,
                                   String userId,
                                   String groupId)

Specified by:

deleteCandidateStarter in interface Flowable5CompatibilityHandler

suspendProcessDefinition

public void suspendProcessDefinition(String processDefinitionId,
                                     String processDefinitionKey,
                                     boolean suspendProcessInstances,
                                     Date suspensionDate,
                                     String tenantId)

Specified by:

suspendProcessDefinition in interface Flowable5CompatibilityHandler

activateProcessDefinition

public void activateProcessDefinition(String processDefinitionId,
                                      String processDefinitionKey,
                                      boolean activateProcessInstances,
                                      Date activationDate,
                                      String tenantId)

Specified by:

activateProcessDefinition in interface Flowable5CompatibilityHandler

setProcessDefinitionCategory

public void setProcessDefinitionCategory(String processDefinitionId,
                                         String category)

Specified by:

setProcessDefinitionCategory in interface Flowable5CompatibilityHandler

deploy

public Deployment deploy(DeploymentBuilderImpl activiti6DeploymentBuilder)

Specified by:

deploy in interface Flowable5CompatibilityHandler

setDeploymentCategory

public void setDeploymentCategory(String deploymentId,
                                  String category)

Specified by:

setDeploymentCategory in interface Flowable5CompatibilityHandler

changeDeploymentTenantId

public void changeDeploymentTenantId(String deploymentId,
                                     String newTenantId)

Specified by:

changeDeploymentTenantId in interface Flowable5CompatibilityHandler

deleteDeployment

public void deleteDeployment(String deploymentId,
                             boolean cascade)

Specified by:

deleteDeployment in interface Flowable5CompatibilityHandler

startProcessInstance

public ProcessInstance startProcessInstance(String processDefinitionKey,
                                            String processDefinitionId,
                                            Map<String,Object> variables,
                                            Map<String,Object> transientVariables,
                                            String businessKey,
                                            String tenantId,
                                            String processInstanceName)

Specified by:

startProcessInstance in interface Flowable5CompatibilityHandler

startProcessInstanceByMessage

public ProcessInstance startProcessInstanceByMessage(String messageName,
                                                     Map<String,Object> variables,
                                                     Map<String,Object> transientVariables,
                                                     String businessKey,
                                                     String tenantId)

Specified by:

startProcessInstanceByMessage in interface Flowable5CompatibilityHandler

getProcessInstance

public ProcessInstance getProcessInstance(String processInstanceId)

Specified by:

getProcessInstance in interface Flowable5CompatibilityHandler

setProcessInstanceName

public void setProcessInstanceName(String processInstanceId,
                                   String processInstanceName)

Specified by:

setProcessInstanceName in interface Flowable5CompatibilityHandler

getExecutionVariable

public Object getExecutionVariable(String executionId,
                                   String variableName,
                                   boolean isLocal)

Specified by:

getExecutionVariable in interface Flowable5CompatibilityHandler

getExecutionVariableInstance

public VariableInstance getExecutionVariableInstance(String executionId,
                                                     String variableName,
                                                     boolean isLocal)

Specified by:

getExecutionVariableInstance in interface Flowable5CompatibilityHandler

getExecutionVariables

public Map<String,Object> getExecutionVariables(String executionId,
                                                Collection<String> variableNames,
                                                boolean isLocal)

Specified by:

getExecutionVariables in interface Flowable5CompatibilityHandler

getExecutionVariableInstances

public Map<String,VariableInstance> getExecutionVariableInstances(String executionId,
                                                                  Collection<String> variableNames,
                                                                  boolean isLocal)

Specified by:

getExecutionVariableInstances in interface Flowable5CompatibilityHandler

setExecutionVariables

public void setExecutionVariables(String executionId,
                                  Map<String,? extends Object> variables,
                                  boolean isLocal)

Specified by:

setExecutionVariables in interface Flowable5CompatibilityHandler

removeExecutionVariables

public void removeExecutionVariables(String executionId,
                                     Collection<String> variableNames,
                                     boolean isLocal)

Specified by:

removeExecutionVariables in interface Flowable5CompatibilityHandler

updateBusinessKey

public void updateBusinessKey(String processInstanceId,
                              String businessKey)

Specified by:

updateBusinessKey in interface Flowable5CompatibilityHandler

suspendProcessInstance

public void suspendProcessInstance(String processInstanceId)

Specified by:

suspendProcessInstance in interface Flowable5CompatibilityHandler

activateProcessInstance

public void activateProcessInstance(String processInstanceId)

Specified by:

activateProcessInstance in interface Flowable5CompatibilityHandler

deleteProcessInstance

public void deleteProcessInstance(String processInstanceId,
                                  String deleteReason)

Specified by:

deleteProcessInstance in interface Flowable5CompatibilityHandler

deleteHistoricProcessInstance

public void deleteHistoricProcessInstance(String processInstanceId)

Specified by:

deleteHistoricProcessInstance in interface Flowable5CompatibilityHandler

addIdentityLinkForProcessInstance

public void addIdentityLinkForProcessInstance(String processInstanceId,
                                              String userId,
                                              String groupId,
                                              String identityLinkType)

Specified by:

addIdentityLinkForProcessInstance in interface Flowable5CompatibilityHandler

deleteIdentityLinkForProcessInstance

public void deleteIdentityLinkForProcessInstance(String processInstanceId,
                                                 String userId,
                                                 String groupId,
                                                 String identityLinkType)

Specified by:

deleteIdentityLinkForProcessInstance in interface Flowable5CompatibilityHandler

completeTask

public void completeTask(TaskEntity taskEntity,
                         Map<String,Object> variables,
                         boolean localScope)

Specified by:

completeTask in interface Flowable5CompatibilityHandler

completeTask

public void completeTask(TaskEntity taskEntity,
                         Map<String,Object> variables,
                         Map<String,Object> transientVariables)

Specified by:

completeTask in interface Flowable5CompatibilityHandler

claimTask

public void claimTask(String taskId,
                      String userId)

Specified by:

claimTask in interface Flowable5CompatibilityHandler

setTaskVariables

public void setTaskVariables(String taskId,
                             Map<String,? extends Object> variables,
                             boolean isLocal)

Specified by:

setTaskVariables in interface Flowable5CompatibilityHandler

removeTaskVariables

public void removeTaskVariables(String taskId,
                                Collection<String> variableNames,
                                boolean isLocal)

Specified by:

removeTaskVariables in interface Flowable5CompatibilityHandler

setTaskDueDate

public void setTaskDueDate(String taskId,
                           Date dueDate)

Specified by:

setTaskDueDate in interface Flowable5CompatibilityHandler

setTaskPriority

public void setTaskPriority(String taskId,
                            int priority)

Specified by:

setTaskPriority in interface Flowable5CompatibilityHandler

deleteTask

public void deleteTask(String taskId,
                       String deleteReason,
                       boolean cascade)

Specified by:

deleteTask in interface Flowable5CompatibilityHandler

deleteHistoricTask

public void deleteHistoricTask(String taskId)

Specified by:

deleteHistoricTask in interface Flowable5CompatibilityHandler

getStartFormData

public StartFormData getStartFormData(String processDefinitionId)

Specified by:

getStartFormData in interface Flowable5CompatibilityHandler

getFormKey

public String getFormKey(String processDefinitionId,
                         String taskDefinitionKey)

Specified by:

getFormKey in interface Flowable5CompatibilityHandler

getRenderedStartForm

public Object getRenderedStartForm(String processDefinitionId,
                                   String formEngineName)

Specified by:

getRenderedStartForm in interface Flowable5CompatibilityHandler

submitStartFormData

public ProcessInstance submitStartFormData(String processDefinitionId,
                                           String businessKey,
                                           Map<String,String> properties)

Specified by:

submitStartFormData in interface Flowable5CompatibilityHandler

getTaskFormData

public TaskFormData getTaskFormData(String taskId)

Specified by:

getTaskFormData in interface Flowable5CompatibilityHandler

submitTaskFormData

public void submitTaskFormData(String taskId,
                               Map<String,String> properties,
                               boolean completeTask)

Specified by:

submitTaskFormData in interface Flowable5CompatibilityHandler

saveTask

public void saveTask(TaskEntity task)

Specified by:

saveTask in interface Flowable5CompatibilityHandler

addIdentityLink

public void addIdentityLink(String taskId,
                            String identityId,
                            int identityIdType,
                            String identityType)

Specified by:

addIdentityLink in interface Flowable5CompatibilityHandler

deleteIdentityLink

public void deleteIdentityLink(String taskId,
                               String userId,
                               String groupId,
                               String identityLinkType)

Specified by:

deleteIdentityLink in interface Flowable5CompatibilityHandler

addComment

public Comment addComment(String taskId,
                          String processInstanceId,
                          String type,
                          String message)

Specified by:

addComment in interface Flowable5CompatibilityHandler

deleteComment

public void deleteComment(String commentId,
                          String taskId,
                          String processInstanceId)

Specified by:

deleteComment in interface Flowable5CompatibilityHandler

createAttachment

public Attachment createAttachment(String attachmentType,
                                   String taskId,
                                   String processInstanceId,
                                   String attachmentName,
                                   String attachmentDescription,
                                   InputStream content,
                                   String url)

Specified by:

createAttachment in interface Flowable5CompatibilityHandler

saveAttachment

public void saveAttachment(Attachment attachment)

Specified by:

saveAttachment in interface Flowable5CompatibilityHandler

deleteAttachment

public void deleteAttachment(String attachmentId)

Specified by:

deleteAttachment in interface Flowable5CompatibilityHandler

trigger

public void trigger(String executionId,
                    Map<String,Object> processVariables,
                    Map<String,Object> transientVariables)

Specified by:

trigger in interface Flowable5CompatibilityHandler

messageEventReceived

public void messageEventReceived(String messageName,
                                 String executionId,
                                 Map<String,Object> processVariables,
                                 boolean async)

Specified by:

messageEventReceived in interface Flowable5CompatibilityHandler

signalEventReceived

public void signalEventReceived(String signalName,
                                String executionId,
                                Map<String,Object> processVariables,
                                boolean async,
                                String tenantId)

Specified by:

signalEventReceived in interface Flowable5CompatibilityHandler

signalEventReceived

public void signalEventReceived(SignalEventSubscriptionEntity signalEventSubscriptionEntity,
                                Object payload,
                                boolean async)

Specified by:

signalEventReceived in interface Flowable5CompatibilityHandler

executeJob

public void executeJob(Job job)

Specified by:

executeJob in interface Flowable5CompatibilityHandler

executeJobWithLockAndRetry

public void executeJobWithLockAndRetry(Job job)

Specified by:

executeJobWithLockAndRetry in interface Flowable5CompatibilityHandler

handleFailedJob

public void handleFailedJob(Job job,
                            Throwable exception)

Specified by:

handleFailedJob in interface Flowable5CompatibilityHandler

deleteJob

public void deleteJob(String jobId)

Specified by:

deleteJob in interface Flowable5CompatibilityHandler

leaveExecution

public void leaveExecution(DelegateExecution execution)

Specified by:

leaveExecution in interface Flowable5CompatibilityHandler

propagateError

public void propagateError(BpmnError bpmnError,
                           DelegateExecution execution)

Specified by:

propagateError in interface Flowable5CompatibilityHandler

mapException

public boolean mapException(Exception camelException,
                            DelegateExecution execution,
                            List<MapExceptionEntry> mapExceptions)

Specified by:

mapException in interface Flowable5CompatibilityHandler

getVariables

public Map<String,Object> getVariables(ProcessInstance processInstance)

Specified by:

getVariables in interface Flowable5CompatibilityHandler

getScriptingEngineValue

public Object getScriptingEngineValue(String payloadExpressionValue,
                                      String languageValue,
                                      DelegateExecution execution)

Specified by:

getScriptingEngineValue in interface Flowable5CompatibilityHandler

throwErrorEvent

public void throwErrorEvent(FlowableEvent event)

Specified by:

throwErrorEvent in interface Flowable5CompatibilityHandler

setClock

public void setClock(Clock clock)

Specified by:

setClock in interface Flowable5CompatibilityHandler

resetClock

public void resetClock()

Specified by:

resetClock in interface Flowable5CompatibilityHandler

getRawProcessEngine

public Object getRawProcessEngine()

Specified by:

getRawProcessEngine in interface Flowable5CompatibilityHandler

getRawProcessConfiguration

public Object getRawProcessConfiguration()

Specified by:

getRawProcessConfiguration in interface Flowable5CompatibilityHandler

getRawCommandExecutor

public Object getRawCommandExecutor()

Specified by:

getRawCommandExecutor in interface Flowable5CompatibilityHandler

getCamelContextObject

public Object getCamelContextObject(String camelContextValue)

Specified by:

getCamelContextObject in interface Flowable5CompatibilityHandler

setJobProcessor

public void setJobProcessor(List<Object> flowable5JobProcessors)

Specified by:

setJobProcessor in interface Flowable5CompatibilityHandler

getProcessEngine

protected ProcessEngine getProcessEngine()

getProcessEngineFactory

public DefaultProcessEngineFactory getProcessEngineFactory()

setProcessEngineFactory

public void setProcessEngineFactory(DefaultProcessEngineFactory processEngineFactory)

getFlowable6ProcessEngineConfiguration

public ProcessEngineConfiguration getFlowable6ProcessEngineConfiguration()

Specified by:

getFlowable6ProcessEngineConfiguration in interface Flowable5CompatibilityHandler

setFlowable6ProcessEngineConfiguration

public void setFlowable6ProcessEngineConfiguration(ProcessEngineConfiguration flowable6ProcessEngineConfiguration)

Specified by:

setFlowable6ProcessEngineConfiguration in interface Flowable5CompatibilityHandler

convertToActiviti5TaskEntity

protected TaskEntity convertToActiviti5TaskEntity(TaskEntity task)

convertToActiviti5JobEntity

protected JobEntity convertToActiviti5JobEntity(JobEntity job)

handleActivitiException

protected void handleActivitiException(ActivitiException e)

callJobProcessors

protected void callJobProcessors(JobProcessorContext.Phase processorType,
                                 AbstractJobEntity abstractJobEntity,
                                 ProcessEngineConfigurationImpl processEngineConfiguration)