public class StreamPlugin extends AbstractStreamPlugin
JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNELlogger, PLUGIN_CONTEXT_CONFIG_ROOT| Constructor and Description |
|---|
StreamPlugin(MessageBus messageBus,
ZooKeeperConnection zkConnection) |
| Modifier and Type | Method and Description |
|---|---|
int |
getOrder() |
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 |
preProcessModule(Module module)
Apply changes to the module before it is initialized i.e. before its context is refreshed.
|
buildTapChannelName, getInputChannelName, getOutputChannelName, supportsbeforeShutdown, bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, removeModule, unbindConsumer, unbindProducersgetApplicationContext, setApplicationContext@Autowired public StreamPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection)
public void preProcessModule(Module module)
PluginpreProcessModule in interface PluginpreProcessModule in class AbstractPluginmodule - the module to pre-processpublic void postProcessModule(Module module)
PluginpostProcessModule in interface PluginpostProcessModule in class AbstractPluginmodule - the module to post-processpublic int getOrder()
getOrder in interface org.springframework.core.OrderedgetOrder in class AbstractMessageBusBinderPlugin