public class JobEventsListenerPlugin extends AbstractJobPlugin implements XDJobListenerConstants
JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNEL
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 |
---|---|
static java.lang.String |
getEventListenerChannelName(java.lang.String jobName) |
static java.util.Map<java.lang.String,java.lang.String> |
getEventListenerChannels(java.lang.String jobName) |
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, 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 static java.util.Map<java.lang.String,java.lang.String> getEventListenerChannels(java.lang.String jobName)
jobName
- the job name.public static java.lang.String getEventListenerChannelName(java.lang.String jobName)
jobName
- the job name.public void removeModule(Module module)
Plugin
removeModule
in interface Plugin
removeModule
in class AbstractMessageBusBinderPlugin
module
- the module to remove