クラス MessageChannelItemWriter<T>

java.lang.ObjectSE
org.springframework.batch.integration.support.MessageChannelItemWriter<T>
型パラメーター:
T - 書き込む項目の種類
実装済みのインターフェース一覧:
ItemWriter<T>
public class MessageChannelItemWriter<T> extends ObjectSE implements ItemWriter<T>
MessagingTemplate を使用してアイテムをメッセージとしてメッセージチャネルに送信する ItemWriter 実装。このアイテムライターは、メッセージングを通じてアイテムの生成と消費を切り離すことで、Spring Batch ジョブで SEDA (ステージングイベントドリブンアーキテクチャ) パターンを実現します。
導入:
6.0.0
作成者:
Mahmoud Ben Hassine

  • コンストラクターの詳細

    • MessageChannelItemWriter

      public MessageChannelItemWriter(org.springframework.integration.core.MessagingTemplate messagingGateway)
      新しい MessageChannelItemWriter インスタンスを作成します。メッセージは、指定された MessagingTemplate のデフォルトの宛先に送信されます。この宛先は null であってはなりません。
      パラメーター:
      messagingGateway - メッセージを送信するために使用するメッセージングテンプレート

    • MessageChannelItemWriter

      public MessageChannelItemWriter(org.springframework.integration.core.MessagingTemplate messagingTemplate, org.springframework.messaging.MessageChannel messageChannel)
      新しい MessageChannelItemWriter インスタンスを作成します。メッセージは指定されたメッセージチャネルに送信されます。
      パラメーター:
      messagingTemplate - メッセージを送信するために使用するメッセージングテンプレート
      messageChannel - メッセージを送信するメッセージチャネル

  • 方法の詳細

    • setMessageChannel

      public void setMessageChannel(org.springframework.messaging.MessageChannel messageChannel)
      ターゲットメッセージチャネルを設定します。
      パラメーター:
      messageChannel - メッセージを送信するメッセージチャネル

    • write

      public void write(Chunk<? extends T> items) throws ExceptionSE
      インターフェースからコピーされた説明: ItemWriter
      指定されたデータ要素を処理します。通常の動作では null 項目が渡されることはありませんが、たとえばすべての項目が ItemProcessor によってフィルタリングされた場合や、フォールトトレラントステップ処理によってスキップされた場合など、空のチャンクが渡される可能性があります。実装では、空のチャンクを適切に処理することが求められます。
      次で指定:
      インターフェース ItemWriter<T> 内の write 
      パラメーター:
      items - 記入すべき項目。null は不可だが、空欄でも構わない。
      例外:
      ExceptionSE - エラーがある場合。フレームワークは例外をキャッチし、必要に応じて変換または再スローします。

Copyright © 2026 Spring. All rights reserved.