Package com.flowable.agent.engine.impl.callback

Class DefaultInternalAgentJobManager

java.lang.Object

com.flowable.agent.engine.impl.callback.DefaultInternalAgentJobManager

All Implemented Interfaces:

org.flowable.job.service.InternalJobManager

public class DefaultInternalAgentJobManager
extends Object
implements org.flowable.job.service.InternalJobManager

Field Summary

Fields

Modifier and Type	Field	Description
protected final AgentEngineConfiguration	agentEngineConfiguration

Constructor Summary

Constructors

Constructor	Description
DefaultInternalAgentJobManager(AgentEngineConfiguration agentEngineConfiguration)

Method Summary

Modifier and Type	Method	Description
void	clearJobScopeLock(org.flowable.job.api.Job job)
protected void	clearScopeLock(String scopeId, String scopeType)
protected String	getScopeIdForCallbackId(String callbackId, String callbackType)
void	handleJobDelete(org.flowable.job.api.Job job)
boolean	handleJobInsert(org.flowable.job.api.Job job)
void	lockJobScope(org.flowable.job.api.Job job)
protected void	lockScope(String scopeId, String scopeType, String lockOwner, Date lockExpirationTime)
void	preRepeatedTimerSchedule(org.flowable.job.service.impl.persistence.entity.TimerJobEntity timerJobEntity, org.flowable.variable.api.delegate.VariableScope variableScope)
void	preTimerJobDelete(org.flowable.job.service.impl.persistence.entity.JobEntity jobEntity, org.flowable.variable.api.delegate.VariableScope variableScope)
void	registerScopedInternalJobManager(String scopeType, org.flowable.job.service.InternalJobManager internalJobManager)
org.flowable.variable.api.delegate.VariableScope	resolveVariableScope(org.flowable.job.api.Job job)
Map<String,Object>	resolveVariablesForExternalWorkerJob(org.flowable.job.api.ExternalWorkerJob job)

Methods inherited from class java.lang.Object

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

Field Details

agentEngineConfiguration

protected final AgentEngineConfiguration agentEngineConfiguration

Constructor Details

DefaultInternalAgentJobManager

public DefaultInternalAgentJobManager(AgentEngineConfiguration agentEngineConfiguration)

Method Details

resolveVariableScope

public org.flowable.variable.api.delegate.VariableScope resolveVariableScope(org.flowable.job.api.Job job)

Specified by:

resolveVariableScope in interface org.flowable.job.service.InternalJobManager

resolveVariablesForExternalWorkerJob

public Map<String,Object> resolveVariablesForExternalWorkerJob(org.flowable.job.api.ExternalWorkerJob job)

Specified by:

resolveVariablesForExternalWorkerJob in interface org.flowable.job.service.InternalJobManager

handleJobInsert

public boolean handleJobInsert(org.flowable.job.api.Job job)

Specified by:

handleJobInsert in interface org.flowable.job.service.InternalJobManager

handleJobDelete

public void handleJobDelete(org.flowable.job.api.Job job)

Specified by:

handleJobDelete in interface org.flowable.job.service.InternalJobManager

lockJobScope

public void lockJobScope(org.flowable.job.api.Job job)

Specified by:

lockJobScope in interface org.flowable.job.service.InternalJobManager

lockScope

protected void lockScope(String scopeId,
 String scopeType,
 String lockOwner,
 Date lockExpirationTime)

clearJobScopeLock

public void clearJobScopeLock(org.flowable.job.api.Job job)

Specified by:

clearJobScopeLock in interface org.flowable.job.service.InternalJobManager

clearScopeLock

protected void clearScopeLock(String scopeId,
 String scopeType)

preTimerJobDelete

public void preTimerJobDelete(org.flowable.job.service.impl.persistence.entity.JobEntity jobEntity,
 org.flowable.variable.api.delegate.VariableScope variableScope)

Specified by:

preTimerJobDelete in interface org.flowable.job.service.InternalJobManager

preRepeatedTimerSchedule

public void preRepeatedTimerSchedule(org.flowable.job.service.impl.persistence.entity.TimerJobEntity timerJobEntity,
 org.flowable.variable.api.delegate.VariableScope variableScope)

Specified by:

preRepeatedTimerSchedule in interface org.flowable.job.service.InternalJobManager

registerScopedInternalJobManager

public void registerScopedInternalJobManager(String scopeType,
 org.flowable.job.service.InternalJobManager internalJobManager)

Specified by:

registerScopedInternalJobManager in interface org.flowable.job.service.InternalJobManager

getScopeIdForCallbackId

protected String getScopeIdForCallbackId(String callbackId,
 String callbackType)