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, supportsprotected 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)
PluginPlugin 内の beforeShutdown AbstractPlugin の beforeShutdown module - クリーンアップするモジュール public void removeModule(Module module)
PluginPlugin 内の 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