クラス OrderedMessageChannelDecorator
java.lang.ObjectSE
org.springframework.messaging.simp.broker.OrderedMessageChannelDecorator
- 実装されたすべてのインターフェース:
MessageChannel
メッセージがチャネルにパブリッシュされた順序で処理されることを保証する
ExecutorSubscribableChannel
のデコレーター。メッセージは一度に 1 つずつ送信され、前のメッセージが処理されると次のメッセージが解放されます。このデコレーターは、セッションごとに適用されることを意図しています。- 導入:
- 5.1
- 作成者:
- Rossen Stoyanchev
フィールドサマリー
インターフェース org.springframework.messaging.MessageChannel から継承されたフィールド
INDEFINITE_TIMEOUT
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明static void
configureInterceptor
(MessageChannel channel, boolean preserveOrder) メッセージのヘッダーにある場合は、完了タスクを呼び出すExecutorChannelInterceptor
をインストールまたは削除します。static RunnableSE
getNextMessageTask
(Message<?> message) 見つかった場合は、次のメッセージを解放するタスクを取得します。boolean
Message
をこのチャネルに送信します。boolean
メッセージを送信し、メッセージが受け入れられるか、指定されたタイムアウト期間が経過するまでブロックします。
コンストラクターの詳細
OrderedMessageChannelDecorator
メソッドの詳細
send
インターフェースからコピーされた説明:MessageChannel
このチャネルにMessage
を送信します。メッセージが正常に送信されると、メソッドはtrue
を返します。致命的でない理由でメッセージを送信できない場合、メソッドはfalse
を返します。このメソッドは、回復不可能なエラーが発生した場合に RuntimeException をスローすることもあります。このメソッドは、実装によっては無期限にブロックされる場合があります。最大待機時間を提供するには、
MessageChannel.send(Message, long)
を使用します。- 次で指定:
- インターフェース
MessageChannel
のsend
- パラメーター:
message
- 送信するメッセージ- 戻り値:
- メッセージが送信されたかどうか
send
インターフェースからコピーされた説明:MessageChannel
メッセージを送信し、メッセージが受け入れられるか、指定されたタイムアウト期間が経過するまでブロックします。- 次で指定:
- インターフェース
MessageChannel
のsend
- パラメーター:
message
- 送信するメッセージtimeout
- ミリ秒単位のタイムアウトまたはMessageChannel.INDEFINITE_TIMEOUT
- 戻り値:
- メッセージが送信された場合は
true
、送信の割り込みのタイムアウトが含まれていない場合はfalse
getNextMessageTask
見つかった場合は、次のメッセージを解放するタスクを取得します。configureInterceptor
メッセージのヘッダーにある場合は、完了タスクを呼び出すExecutorChannelInterceptor
をインストールまたは削除します。- パラメーター:
channel
- 構成するチャネルpreserveOrder
- オーダーまたは公開を保持するかどうか。"true" の場合はインターセプターが挿入され、"false" の場合は削除されます。