public class JobPartitionerPlugin extends AbstractJobPlugin
JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNELlogger, PLUGIN_CONTEXT_CONFIG_ROOT| Constructor and Description |
|---|
JobPartitionerPlugin(MessageBus messageBus) |
| Modifier and Type | Method and Description |
|---|---|
void |
beforeShutdown(Module module)
Perform any cleanup necessary prior to module shutdown
|
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.
|
buildTapChannelName, getInputChannelName, getJobChannelName, getOutputChannelName, supportsbindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, unbindConsumer, unbindProducersgetApplicationContext, preProcessModule, setApplicationContextpublic JobPartitionerPlugin(MessageBus messageBus)
public void postProcessModule(Module module)
PluginpostProcessModule in interface PluginpostProcessModule in class AbstractPluginmodule - the module to post-processpublic void beforeShutdown(Module module)
PluginbeforeShutdown in interface PluginbeforeShutdown in class AbstractMessageBusBinderPluginmodule - the module to cleanuppublic void removeModule(Module module)
PluginremoveModule in interface PluginremoveModule in class AbstractMessageBusBinderPluginmodule - the module to remove