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

Class MessageBasedJobManagerConfigurator

java.lang.Object

org.activiti.cloud.services.job.executor.MessageBasedJobManagerConfigurator

All Implemented Interfaces:

org.activiti.engine.cfg.ProcessEngineConfigurator, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class MessageBasedJobManagerConfigurator
extends Object
implements org.activiti.engine.cfg.ProcessEngineConfigurator, org.springframework.context.SmartLifecycle

Field Summary

Fields

Modifier and Type	Field	Description
static String	JOB_MESSAGE_HANDLER

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor

Description

MessageBasedJobManagerConfigurator(org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory, org.springframework.cloud.stream.binding.BindingService bindingService, JobMessageInputChannelFactory inputChannelFactory, MessageBasedJobManagerFactory messageBasedJobManagerFactory, JobMessageHandlerFactory jobMessageHandlerFactory, org.springframework.cloud.stream.binder.ConsumerProperties consumerProperties)

Method Summary

Modifier and Type	Method	Description
void	beforeInit(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)	Configures MessageBasedJobManager
void	configure(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)	Configures input channel
protected org.springframework.messaging.MessageHandler	createJobMessageHandler(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)
protected MessageBasedJobManager	createMessageBasedJobManager(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)
int	getPriority()
boolean	isRunning()
protected <T> T	registerBean(String name, T bean)
void	setContentType(String contentType)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, isAutoStartup, stop

Field Detail

JOB_MESSAGE_HANDLER

public static final String JOB_MESSAGE_HANDLER

See Also:

Constant Field Values

Constructor Detail

MessageBasedJobManagerConfigurator

public MessageBasedJobManagerConfigurator(org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory,
                                          org.springframework.cloud.stream.binding.BindingService bindingService,
                                          JobMessageInputChannelFactory inputChannelFactory,
                                          MessageBasedJobManagerFactory messageBasedJobManagerFactory,
                                          JobMessageHandlerFactory jobMessageHandlerFactory,
                                          org.springframework.cloud.stream.binder.ConsumerProperties consumerProperties)

Method Detail

createJobMessageHandler

protected org.springframework.messaging.MessageHandler createJobMessageHandler(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)

createMessageBasedJobManager

protected MessageBasedJobManager createMessageBasedJobManager(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)

beforeInit

public void beforeInit(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)

Configures MessageBasedJobManager

Specified by:

beforeInit in interface org.activiti.engine.cfg.ProcessEngineConfigurator

configure

public void configure(org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl configuration)

Configures input channel

Specified by:

configure in interface org.activiti.engine.cfg.ProcessEngineConfigurator

getPriority

public int getPriority()

Specified by:

getPriority in interface org.activiti.engine.cfg.ProcessEngineConfigurator

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

setContentType

public void setContentType(String contentType)

registerBean

protected <T> T registerBean(String name,
                             T bean)