クラスの使用
org.springframework.integration.endpoint.AbstractMessageSource

RabbitMQ のポーリング可能な MessageSource。

フェッチするリモートオブジェクトの数を制限できるメッセージソース。

エンドポイントをポーリングするために、基盤となる MessageProcessorMessageSource.messageProcessor から Message を生成するための MessageSource 戦略の実装。

MessageSource のこの実装は、'feedUrl' 属性で識別されるフィードの個々の SyndEntry を生成します。

ファイルシステムディレクトリからメッセージを作成する MessageSource。

リモートファイルを参照する InputStreamSE ペイロードを含むメッセージを生成するメッセージソース。

FTP アダプターと SFTP アダプター間の共通ロジックを除外します。

FTP 用の MessageSource 実装。

Hazelcast 分散 SQL メッセージソースは、クラスター内で定義された分散クエリを実行し、反復型に照らして結果を返すメッセージソースです。

選択クエリを実行して返されたペイロードからメッセージを作成するポーリングチャネルアダプター。

ポーリングリスナーで JMS メッセージを受信するためのソース。

receive() が呼び出されるたびに JMX 属性の現在の値を取得する MessageSource 実装。

提供された結果からメッセージを生成するポーリングメッセージソース: entityClass、JpQl、Select Query、Sql Native Query、JpQl、Named Query、Sql Native Named Query。

Apache Kafka のポーリングされたメッセージソース。

MailReceiver に委譲してメールボックスをポーリングする MessageSource 実装。

一般的な MongoDB ソースオプションとサポートメソッドの AbstractMessageSource 拡張。

Query の実行の結果であるペイロードを含む Message を返す MessageSource のインスタンス。

クエリの実行結果であるペイロードを含む Message を返す MessageSource のインスタンス。

ビューを表すメッセージを Redis ストアに返す受信チャネルアダプター。

指定されたパターンに基づいて Resource を解決しようとする ResourcePatternResolver に基づく MessageSource の実装。

エンドポイントをポーリングするために、基盤となる ScriptExecutingMessageSource.scriptMessageProcessor から Message を生成するための MessageSource 戦略の実装。

InboundFileSynchronizer に委譲する SFTP の MessageSource 実装。

SMB の MessageSource 実装。

InputStreamSE からバイトを受信するためのポーリング可能なソース。