org.springframework.xd.dirt.plugins.job

Class JobPartitionerPlugin

java.lang.Object

org.springframework.xd.dirt.plugins.AbstractPlugin

org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

org.springframework.xd.dirt.plugins.AbstractJobPlugin

org.springframework.xd.dirt.plugins.job.JobPartitionerPlugin

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, Plugin

public class JobPartitionerPlugin
extends AbstractJobPlugin

Plugin to enable job partitioning.

Since:

1.0

Author:

Gary Russell, Ilayaperumal Gopinathan

Field Summary

Fields inherited from class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNEL, TAP_CHANNEL_PREFIX, TOPIC_CHANNEL_PREFIX

Fields inherited from class org.springframework.xd.dirt.plugins.AbstractPlugin

logger, PLUGIN_CONTEXT_CONFIG_ROOT

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
JobPartitionerPlugin(MessageBus messageBus)

Method Summary

Methods

Modifier and Type	Method and Description
void	postProcessModule(Module module) Apply changes to the module after it is initialized i.e. after its context is refreshed, but before it is started.
void	removeModule(Module module) Take any actions necessary to remove a module from the system.

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractJobPlugin

buildTapChannelName, getInputChannelName, getOutputChannelName, supports

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin

bindConsumerAndProducers, extractConsumerProducerProperties, getOrder, unbindConsumerAndProducers

Methods inherited from class org.springframework.xd.dirt.plugins.AbstractPlugin

beforeShutdown, getApplicationContext, preProcessModule, setApplicationContext

Methods inherited from class java.lang.Object

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

Constructor Detail

JobPartitionerPlugin

public JobPartitionerPlugin(MessageBus messageBus)

Method Detail

postProcessModule

public void postProcessModule(Module module)

Description copied from interface: Plugin

Apply changes to the module after it is initialized i.e. after its context is refreshed, but before it is started.

Specified by:

postProcessModule in interface Plugin

Overrides:

postProcessModule in class AbstractPlugin

removeModule

public void removeModule(Module module)

Description copied from interface: Plugin

Take any actions necessary to remove a module from the system.

Specified by:

removeModule in interface Plugin

Overrides:

removeModule in class AbstractPlugin