public class MessageSourcePollerInterceptor
extends java.lang.Object
implements org.springframework.messaging.support.ChannelInterceptor, org.springframework.beans.factory.InitializingBean
ChannelInterceptor
: クライアントがチャネルで receive()
を呼び出すと、MessageSource
に委譲して、外部ソースから直接メッセージをプルします。これは、スレッドスコープ内のメッセージチャネルと組み合わせて特に役立ちます。この場合、receive()
は、呼び出し元によって開始されたトランザクションに参加できます。コンストラクターと説明 |
---|
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) |
public MessageSourcePollerInterceptor()
public MessageSourcePollerInterceptor(org.springframework.integration.core.MessageSource<?> source)
source
- 受信時にメッセージをポーリングするためのメッセージソース。public void setChannel(org.springframework.messaging.MessageChannel channel)
preReceive(MessageChannel)
でインターセプトされたチャネル)。channel
- 設定するチャネル public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception
InitializingBean.afterPropertiesSet()
public void setMessageSource(org.springframework.integration.core.MessageSource<?> source)
source
- 受信時にメッセージをポーリングするためのメッセージソース。public boolean preReceive(org.springframework.messaging.MessageChannel channel)
MessageSource
から受信し、すぐに入力チャネルに送信するため、インターセプトしている呼び出しは常に受信するメッセージです。org.springframework.messaging.support.ChannelInterceptor
の preReceive
ChannelInterceptor.preReceive(MessageChannel)