public abstract class AbstractMessageBusBinderPlugin extends AbstractPlugin
修飾子と型 | フィールドと説明 |
---|---|
protected static java.lang.String | JOB_CHANNEL_PREFIX |
protected MessageBus | messageBus |
protected static java.lang.String | MODULE_INPUT_CHANNEL |
protected static java.lang.String | MODULE_OUTPUT_CHANNEL |
logger, PLUGIN_CONTEXT_CONFIG_ROOT
コンストラクターと説明 |
---|
AbstractMessageBusBinderPlugin(MessageBus messageBus) |
AbstractMessageBusBinderPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection) |
修飾子と型 | メソッドと説明 |
---|---|
void | beforeShutdown(Module module) モジュールをシャットダウンする前に必要なクリーンアップを実行します |
protected void | bindConsumerAndProducers(Module module) モジュールのメッセージコンシューマー / プロデューサーの入力 / 出力チャネルを MessageBus のメッセージソース / ターゲットエンティティにバインドします。 |
protected abstract java.lang.String | buildTapChannelName(Module module) |
protected java.util.Properties[] | extractConsumerProducerProperties(Module module) |
protected java.util.Map<java.lang.String,java.lang.Object> | extractHistoryProperties(Module module) |
protected abstract java.lang.String | getInputChannelName(Module module) |
int | getOrder() |
protected abstract java.lang.String | getOutputChannelName(Module module) |
void | removeModule(Module module) システムからモジュールを削除するために必要なアクションを実行します。 |
protected void | unbindConsumer(Module module) モジュールの入力チャネルを MessageBus からバインド解除します (モジュールを停止できるように、モジュールへの新しいメッセージの送信を停止します)。 |
protected void | unbindProducers(Module module) モジュールの出力チャネル(および存在する場合はタップ)を MessageBus からバインド解除します(停止後)。 |
getApplicationContext, postProcessModule, preProcessModule, setApplicationContext, supports
protected static final java.lang.String MODULE_INPUT_CHANNEL
protected static final java.lang.String MODULE_OUTPUT_CHANNEL
protected static final java.lang.String JOB_CHANNEL_PREFIX
protected final MessageBus messageBus
public AbstractMessageBusBinderPlugin(MessageBus messageBus)
public AbstractMessageBusBinderPlugin(MessageBus messageBus, ZooKeeperConnection zkConnection)
protected final void bindConsumerAndProducers(Module module)
MessageBus
のメッセージソース / ターゲットエンティティにバインドします。メッセージがコンシューマーからすぐに流れ始めるように、最初にプロデューサーをバインドする必要があります。module
- コンシューマーとプロデューサーを MessageBus
にバインドするモジュール。protected final java.util.Properties[] extractConsumerProducerProperties(Module module)
protected final java.util.Map<java.lang.String,java.lang.Object> extractHistoryProperties(Module module)
public void beforeShutdown(Module module)
Plugin
Plugin
の beforeShutdown
AbstractPlugin
の beforeShutdown
module
- クリーンアップするモジュール public void removeModule(Module module)
Plugin
Plugin
の removeModule
AbstractPlugin
の removeModule
module
- 削除するモジュール protected abstract java.lang.String getInputChannelName(Module module)
protected abstract java.lang.String getOutputChannelName(Module module)
protected abstract java.lang.String buildTapChannelName(Module module)
protected void unbindConsumer(Module module)
MessageBus
からバインド解除します (モジュールを停止できるように、モジュールへの新しいメッセージの送信を停止します)。module
- コンシューマーが MessageBus
からアンバインドされるモジュール。protected void unbindProducers(Module module)
MessageBus
からバインド解除します(停止後)。module
- プロデューサーが MessageBus
からアンバインドされるモジュール。public int getOrder()
org.springframework.core.Ordered
の getOrder
AbstractPlugin
の getOrder