public class JobEventsListenerPlugin extends AbstractJobPlugin implements XDJobListenerConstants
JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNELlogger, PLUGIN_CONTEXT_CONFIG_ROOTCHUNK_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, supportsbeforeShutdown, bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, unbindConsumer, unbindProducersgetApplicationContext, preProcessModule, setApplicationContextpublic JobEventsListenerPlugin(MessageBus messageBus)
public void postProcessModule(Module module)
PluginpostProcessModule in interface PluginpostProcessModule in class AbstractPluginmodule - 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)
PluginremoveModule in interface PluginremoveModule in class AbstractMessageBusBinderPluginmodule - the module to remove