public abstract class AbstractStreamPlugin extends AbstractMessageBusBinderPlugin
AbstractMessageBusBinderPlugin を継承し、ストリームプラグインに関連する共通の実装メソッドを持つ抽象クラス。JOB_CHANNEL_PREFIX, messageBus, MODULE_INPUT_CHANNEL, MODULE_OUTPUT_CHANNELlogger, PLUGIN_CONTEXT_CONFIG_ROOT| コンストラクターと説明 |
|---|
AbstractStreamPlugin(MessageBus messageBus) |
AbstractStreamPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected java.lang.String | buildTapChannelName(Module module) |
protected java.lang.String | getInputChannelName(Module module) |
protected java.lang.String | getOutputChannelName(Module module) |
boolean | supports(Module module) モジュールがプラグインでサポートされているかどうかを確認します。 |
beforeShutdown, bindConsumerAndProducers, extractConsumerProducerProperties, extractHistoryProperties, getOrder, removeModule, unbindConsumer, unbindProducersgetApplicationContext, postProcessModule, preProcessModule, setApplicationContextpublic AbstractStreamPlugin(MessageBus messageBus)
public AbstractStreamPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection)
protected java.lang.String getInputChannelName(Module module)
AbstractMessageBusBinderPlugin の getInputChannelName protected java.lang.String getOutputChannelName(Module module)
AbstractMessageBusBinderPlugin の getOutputChannelName protected java.lang.String buildTapChannelName(Module module)
AbstractMessageBusBinderPlugin の buildTapChannelName