Package org.activiti.cloud.services.job.executor

Class MessageBasedJobManager

java.lang.Object

org.activiti.engine.impl.asyncexecutor.DefaultJobManager

org.activiti.cloud.services.job.executor.MessageBasedJobManager

All Implemented Interfaces:

org.activiti.engine.impl.asyncexecutor.JobManager

public class MessageBasedJobManager
extends org.activiti.engine.impl.asyncexecutor.DefaultJobManager

Field Summary

Fields inherited from class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

processEngineConfiguration

Constructor Summary

Constructors

Constructor	Description
MessageBasedJobManager(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl processEngineConfiguration, RuntimeBundleProperties runtimeBundleProperties, JobMessageProducer jobMessageProducer)

Method Summary

Modifier and Type	Method	Description
String	getDestination()	Scoped destination name by runtime bundle service name
String	getInputChannelName()
void	sendMessage(org.activiti.engine.runtime.Job job)
void	setInputChannelName(String inputChannelName)
protected void	triggerExecutorIfNeeded(org.activiti.engine.impl.persistence.entity.JobEntity jobEntity)
void	unacquire(org.activiti.engine.runtime.Job job)

Methods inherited from class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

activateSuspendedJob, calculateMaxIterationsValue, copyJobInfo, createAsyncJob, createDeadLetterJobFromOtherJob, createExecutableJobFromOtherJob, createSuspendedJobFromOtherJob, createTimerJob, createTimerJobFromOtherJob, execute, executeJobHandler, executeMessageJob, executeTimerJob, fillDefaultAsyncJobInfo, getAsyncExecutor, getBusinessCalendarName, getCommandContext, getExecutionEntityManager, getMaxIterations, getProcessEngineConfiguration, hintAsyncExecutor, internalCreateAsyncJob, internalCreateLockedAsyncJob, isAsyncExecutorActive, isValidTime, moveDeadLetterJobToExecutableJob, moveJobToDeadLetterJob, moveJobToSuspendedJob, moveJobToTimerJob, moveTimerJobToExecutableJob, restoreExtraData, scheduleAsyncJob, scheduleTimerJob, setProcessEngineConfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageBasedJobManager

public MessageBasedJobManager(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl processEngineConfiguration,
                              RuntimeBundleProperties runtimeBundleProperties,
                              JobMessageProducer jobMessageProducer)

Method Detail

triggerExecutorIfNeeded

protected void triggerExecutorIfNeeded(org.activiti.engine.impl.persistence.entity.JobEntity jobEntity)

Overrides:

triggerExecutorIfNeeded in class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

unacquire

public void unacquire(org.activiti.engine.runtime.Job job)

Specified by:

unacquire in interface org.activiti.engine.impl.asyncexecutor.JobManager

Overrides:

unacquire in class org.activiti.engine.impl.asyncexecutor.DefaultJobManager

getDestination

public String getDestination()

Scoped destination name by runtime bundle service name

getInputChannelName

public String getInputChannelName()

setInputChannelName

public void setInputChannelName(String inputChannelName)

sendMessage

public void sendMessage(org.activiti.engine.runtime.Job job)