public class StreamPlugin extends AbstractStreamPlugin
JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNELlogger, PLUGIN_CONTEXT_CONFIG_ROOT| コンストラクターと説明 |
|---|
StreamPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection) |
| 修飾子と型 | メソッドと説明 |
|---|---|
int | getOrder() |
void | postProcessModule(Module module) モジュールが初期化された後 、つまりコンテキストがリフレッシュされた後、モジュールが起動される前に、モジュールに変更を適用します。 |
void | preProcessModule(Module module) モジュールが初期化される前 、つまりコンテキストがリフレッシュされる前に、モジュールに変更を適用します。 |
buildTapChannelName, getInputChannelName, getOutputChannelName, supportsbeforeShutdown, bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, removeModule, unbindConsumer, unbindProducersgetApplicationContext, setApplicationContext@Autowired public StreamPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection)
public void preProcessModule(Module module)
PluginPlugin 内の preProcessModule AbstractPlugin の preProcessModule module - 前処理するモジュール public void postProcessModule(Module module)
PluginPlugin 内の postProcessModule AbstractPlugin の postProcessModule module - 後処理モジュール public int getOrder()
org.springframework.core.Ordered 内の getOrder AbstractMessageBusBinderPlugin の getOrder