org.flowable.spring.executor.jms

Class MessageBasedJobManager

java.lang.Object

org.flowable.job.service.impl.asyncexecutor.DefaultJobManager

org.flowable.job.service.impl.asyncexecutor.message.AbstractMessageBasedJobManager

org.flowable.spring.executor.jms.MessageBasedJobManager

All Implemented Interfaces:

JobManager

public class MessageBasedJobManager
extends AbstractMessageBasedJobManager

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.jms.core.JmsTemplate	historyJmsTemplate
protected org.springframework.jms.core.JmsTemplate	jmsTemplate

Fields inherited from class org.flowable.job.service.impl.asyncexecutor.DefaultJobManager

CYCLE_TYPE, jobServiceConfiguration

Constructor Summary

Constructors

Constructor and Description
MessageBasedJobManager()

Method Summary

Modifier and Type	Method and Description
org.springframework.jms.core.JmsTemplate	getHistoryJmsTemplate()
org.springframework.jms.core.JmsTemplate	getJmsTemplate()
protected void	sendMessage(JobInfo job) Subclasses need to implement this method: it should contain the actual sending of the message using the job data provided in the parameter.
void	setHistoryJmsTemplate(org.springframework.jms.core.JmsTemplate historyJmsTemplate)
void	setJmsTemplate(org.springframework.jms.core.JmsTemplate jmsTemplate)

Methods inherited from class org.flowable.job.service.impl.asyncexecutor.message.AbstractMessageBasedJobManager

prepareAndSendMessage, triggerAsyncHistoryExecutorIfNeeded, triggerExecutorIfNeeded, unacquire, unacquireWithDecrementRetries

Methods inherited from class org.flowable.job.service.impl.asyncexecutor.DefaultJobManager

activateSuspendedJob, bulkMoveTimerJobsToExecutableJobs, callHistoryJobProcessors, callJobProcessors, copyHistoryJobInfo, copyHistoryJobProperties, copyJobInfo, createAsyncHistoryHintListeners, createAsyncJob, createDeadLetterJobFromHistoryJob, createDeadLetterJobFromOtherJob, createExecutableJobFromOtherJob, createExecutableJobFromOtherJob, createExternalWorkerJobFromOtherJob, createHintListeners, createSuspendedJobFromOtherJob, createTimerJobFromOtherJob, execute, executeHistoryJob, executeHistoryJobHandler, executeJobHandler, executeMessageJob, executeTimerJob, fillDefaultAsyncJobInfo, getAsyncExecutor, getAsyncHistoryExecutor, getBusinessCalendarName, getBusinessCalendarName, getCommandContext, getExceptionStacktrace, getJobServiceConfiguration, hintAsyncExecutor, hintAsyncHistoryExecutor, internalCreateAsyncJob, internalCreateLockedAsyncJob, isAsyncExecutorActive, isAsyncExecutorRemainingCapacitySufficient, isAsyncHistoryExecutorActive, isExecutorActive, isValidTime, moveDeadLetterJobToExecutableJob, moveDeadLetterJobToHistoryJob, moveExternalWorkerJobToExecutableJob, moveJobToDeadLetterJob, moveJobToSuspendedJob, moveJobToTimerJob, moveTimerJobToExecutableJob, scheduleAsyncJob, scheduleHistoryJob, scheduleTimerJob, sendMoveToDeadletterEvent, sendTimerScheduledEvent, setJobServiceConfiguration, setLockTimeAndOwner

Methods inherited from class java.lang.Object

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

Field Detail

jmsTemplate

protected org.springframework.jms.core.JmsTemplate jmsTemplate

historyJmsTemplate

protected org.springframework.jms.core.JmsTemplate historyJmsTemplate

Constructor Detail

MessageBasedJobManager

public MessageBasedJobManager()

Method Detail

sendMessage

protected void sendMessage(JobInfo job)

Description copied from class: AbstractMessageBasedJobManager

Subclasses need to implement this method: it should contain the actual sending of the message using the job data provided in the parameter.

Specified by:

sendMessage in class AbstractMessageBasedJobManager

getJmsTemplate

public org.springframework.jms.core.JmsTemplate getJmsTemplate()

setJmsTemplate

public void setJmsTemplate(org.springframework.jms.core.JmsTemplate jmsTemplate)

getHistoryJmsTemplate

public org.springframework.jms.core.JmsTemplate getHistoryJmsTemplate()

setHistoryJmsTemplate

public void setHistoryJmsTemplate(org.springframework.jms.core.JmsTemplate historyJmsTemplate)