パッケージ org.springframework.batch.integration.chunk

クラス MessageSourcePollerInterceptor

java.lang.ObjectSE
org.springframework.batch.integration.chunk.MessageSourcePollerInterceptor
実装されたすべてのインターフェース:
org.springframework.beans.factory.InitializingBean, org.springframework.messaging.support.ChannelInterceptor
public class MessageSourcePollerInterceptor extends ObjectSE implements org.springframework.messaging.support.ChannelInterceptor, org.springframework.beans.factory.InitializingBean
ポーリング可能なチャネルを「パススルーチャネル」に変換する ChannelInterceptor : クライアントがチャネルで receive() を呼び出すと、MessageSource に委譲して、外部ソースから直接メッセージをプルします。これは、スレッドスコープ内のメッセージチャネルと組み合わせて特に役立ちます。この場合、receive() は、呼び出し元によって開始されたトランザクションに参加できます。
作成者:
Dave Syer, Mahmoud Ben Hassine

  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    MessageSourcePollerInterceptor()
    構成のための便利なデフォルトコンストラクター。
    MessageSourcePollerInterceptor(org.springframework.integration.core.MessageSource<?> source)

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    afterPropertiesSet()
    必須プロパティが設定されていることを表明します。
    boolean
    preReceive(org.springframework.messaging.MessageChannel channel)
    MessageSource から受信し、すぐに入力チャネルに送信するため、インターセプトしている呼び出しは常に受信するメッセージです。
    void
    setChannel(org.springframework.messaging.MessageChannel channel)
    ソースから受信したメッセージを挿入するためのオプションの MessageChannel（デフォルトは preReceive(MessageChannel) でインターセプトされたチャネル）。
    void
    setMessageSource(org.springframework.integration.core.MessageSource<?> source)

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

    インターフェース org.springframework.messaging.support.ChannelInterceptor から継承されたメソッド

    afterReceiveCompletion, afterSendCompletion, postReceive, postSend, preSend

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

    • MessageSourcePollerInterceptor

      public MessageSourcePollerInterceptor()
      構成のための便利なデフォルトコンストラクター。

    • MessageSourcePollerInterceptor

      public MessageSourcePollerInterceptor(org.springframework.integration.core.MessageSource<?> source)
      パラメーター:
      source - 受信時にメッセージをポーリングするためのメッセージソース。

  • メソッドの詳細

    • setChannel

      public void setChannel(org.springframework.messaging.MessageChannel channel)
      ソースから受信したメッセージを挿入するためのオプションの MessageChannel（デフォルトは preReceive(MessageChannel) でインターセプトされたチャネル）。
      パラメーター:
      channel - 設定するチャネル

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      必須プロパティが設定されていることを表明します。
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 
      例外:
      ExceptionSE
      関連事項:
      • InitializingBean.afterPropertiesSet()

    • setMessageSource

      public void setMessageSource(org.springframework.integration.core.MessageSource<?> source)
      パラメーター:
      source - 受信時にメッセージをポーリングするためのメッセージソース。

    • preReceive

      public boolean preReceive(org.springframework.messaging.MessageChannel channel)
      MessageSource から受信し、すぐに入力チャネルに送信するため、インターセプトしている呼び出しは常に受信するメッセージです。
      次で指定:
      インターフェース org.springframework.messaging.support.ChannelInterceptor の preReceive 
      関連事項:
      • ChannelInterceptor.preReceive(MessageChannel)