public class JobEventsListenerPlugin extends AbstractJobPlugin implements XDJobListenerConstants
JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNEL, TAP_CHANNEL_PREFIX, TOPIC_CHANNEL_PREFIX
logger, PLUGIN_CONTEXT_CONFIG_ROOT
CHUNK_EVENTS_SUFFIX, ITEM_EVENTS_SUFFIX, JOB_EXECUTION_EVENTS_SUFFIX, SKIP_EVENTS_SUFFIX, STEP_EXECUTION_EVENTS_SUFFIX, XD_AGGREGATED_EVENTS_CHANNEL, XD_CHUNK_EVENTS_CHANNEL, XD_CHUNK_LISTENER_BEAN, XD_ITEM_EVENTS_CHANNEL, XD_ITEM_LISTENER_BEAN, XD_JOB_EXECUTION_EVENTS_CHANNEL, XD_JOB_EXECUTION_LISTENER_BEAN, XD_JOB_LISTENERS_SUFFIXES, XD_SKIP_EVENTS_CHANNEL, XD_SKIP_LISTENER_BEAN, XD_STEP_EXECUTION_EVENTS_CHANNEL, XD_STEP_EXECUTION_LISTENER_BEAN
Constructor and Description |
---|
JobEventsListenerPlugin(MessageBus messageBus) |
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.
|
buildTapChannelName, getInputChannelName, getOutputChannelName, supports
beforeShutdown, bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, unbindConsumer, unbindProducers
getApplicationContext, preProcessModule, setApplicationContext
public JobEventsListenerPlugin(MessageBus messageBus)
public void postProcessModule(Module module)
Plugin
postProcessModule
in interface Plugin
postProcessModule
in class AbstractPlugin
module
- the module to post-processpublic void removeModule(Module module)
Plugin
removeModule
in interface Plugin
removeModule
in class AbstractMessageBusBinderPlugin
module
- the module to remove