インターフェースの使用
org.springframework.integration.core.MessageSource
MessageSource を使用するパッケージ
パッケージ
説明
メッセージ集約に関連するクラスを提供します。
受信エンドポイントをサポートするクラスを提供します。
AOP を使用したメッセージ公開をサポートするクラスを提供します。
構成の基本パッケージ。
Spring Integration Java DSL のルートパッケージ。
エンドポイントに関連するコアクラスを提供します。
受信エンドポイントをサポートするクラスを提供します。
構成用のクラスを提供します。パーサー、名前空間ハンドラー、ファクトリ Bean。
ファイルシステム用の送信チャネルアダプター。
リモートファイルをサポートするための基本パッケージ。
AOP に関連するクラスを提供します。
リモートとローカルファイルディレクトリの同期をサポートするクラスを提供します。
構成用のクラス（パーサー、名前空間ハンドラー）を提供します。
受信エンドポイントをサポートするクラスを提供します。
ランタイムオブジェクトグラフに関連するクラスを提供します。
受信エンドポイントをサポートするクラスを提供します。
JDBC の受信チャネルアダプター。
JMS の受信チャネルアダプター。
JMX サポート用の受信チャネルアダプター。
受信 Spring Integration Jpa コンポーネントを提供します。
Apache Kafka 用の Spring Integration 受信コンポーネントを提供します。
受信チャネルアダプターはメールプロトコルをサポートします。
Mongo 受信チャネルアダプターに関連するクラスを提供します
R2DBC 受信コンポーネントをサポートするためのクラスを提供します。
受信エンドポイントをサポートするクラスを提供します。
Spring
Resource を使用したメッセージングに関連するクラスを提供します スクリプティングサポートのベースパッケージ。
Spring Integration Java DSL のスクリプトコンポーネントサポートを提供します。
構成用のクラス（パーサー、名前空間ハンドラー）を提供します。
受信エンドポイントをサポートするクラスを提供します。
SMB 固有のファイルリストフィルタークラス。
SMB プロトコル用の受信チャネルアダプターの実装。
ストリームサポート用の受信チャネルアダプター。
コンテキスト関連のコンポーネントをテストします。
統合コンポーネントをモックするためのユーティリティ。
コアユーティリティクラスを提供します。
org.springframework.integration.aggregator 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.aggregator のクラスorg.springframework.integration.amqp.inbound 内の MessageSource 使用
org.springframework.integration.aop 内の MessageSource 使用
型 MessageSource のパラメーターを持つ org.springframework.integration.aop のメソッド修飾子と型メソッド説明@Nullable Message<?>CompoundTriggerAdvice.afterReceive(@Nullable Message<?> result, MessageSource<?> source) @Nullable Message<?>MessageSourceMutator.afterReceive(@Nullable Message<?> result, MessageSource<?> source) サブクラスは、ポーリングの結果に基づいてアクションを実行できます。たとえばdefault booleanMessageSourceMutator.beforeReceive(MessageSource<?> source) サブクラスは、このポーリングを続行するかどうかを決定できます。org.springframework.integration.config 内の MessageSource 使用
型 MessageSource のパラメーターを持つ org.springframework.integration.config のメソッドorg.springframework.integration.dsl 内の MessageSource 使用
MessageSource 型の型パラメーターを持つ org.springframework.integration.dsl のクラス型 MessageSource のパラメーターを持つ org.springframework.integration.dsl のメソッド修飾子と型メソッド説明static IntegrationFlowBuilderIntegrationFlow.from(MessageSource<?> messageSource) 提供されたMessageSourceオブジェクトをIntegrationFlowBuilderチェーンに移入します。static IntegrationFlowBuilderIntegrationFlow.from(MessageSource<?> messageSource, @Nullable ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer) 提供されたMessageSourceオブジェクトをIntegrationFlowBuilderチェーンに移入します。protected IntegrationFlowDefinition<?>IntegrationFlowAdapter.from(MessageSource<?> messageSource) protected IntegrationFlowDefinition<?>IntegrationFlowAdapter.from(MessageSource<?> messageSource, ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer) 型 MessageSource の型引数を持つ org.springframework.integration.dsl のメソッドパラメーター修飾子と型メソッド説明static IntegrationFlowBuilderIntegrationFlow.from(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec) 提供されたMessageSourceSpecからの流れるような API を使用して、MessageSourceオブジェクトをIntegrationFlowBuilderチェーンに移入します。static IntegrationFlowBuilderIntegrationFlow.from(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec, @Nullable ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer) 提供されたMessageSourceSpecからの流れるような API を使用して、MessageSourceオブジェクトをIntegrationFlowBuilderチェーンに移入します。protected IntegrationFlowDefinition<?>IntegrationFlowAdapter.from(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec) protected IntegrationFlowDefinition<?>IntegrationFlowAdapter.from(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec, ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer) 型 MessageSource のパラメーターを持つ org.springframework.integration.dsl のコンストラクターorg.springframework.integration.endpoint 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.endpoint のクラス修飾子と型クラス説明classフェッチするリモートオブジェクトの数を制限できるメッセージソース。class抽象メッセージソース。classclassエンドポイントをポーリングするために、基盤となる MessageProcessorMessageSource.messageProcessor からMessageを生成するためのMessageSource戦略の実装。class引数なしのメソッドを呼び出して、その戻り値をチャネルに送信できるようにするMessageSource実装。型 MessageSource のパラメーターを持つ org.springframework.integration.endpoint のメソッド修飾子と型メソッド説明voidSourcePollingChannelAdapter.setSource(MessageSource<?> source) メッセージをポーリングするソースを指定します。型 MessageSource のパラメーターを持つ org.springframework.integration.endpoint のコンストラクター修飾子コンストラクター説明MessageSourcePollingTemplate(MessageSource<?> source) ReactiveMessageSourceProducer(MessageSource<?> messageSource) 提供されたMessageSourceに基づいてインスタンスを作成します。org.springframework.integration.feed.inbound 内の MessageSource 使用
org.springframework.integration.file.config 内の MessageSource 使用
型 MessageSource の引数を持つ型を返す org.springframework.integration.file.config のメソッド修飾子と型メソッド説明protected abstract ClassSE<? extends MessageSource<?>>AbstractRemoteFileStreamingInboundChannelAdapterParser.getMessageSourceClass()org.springframework.integration.file.inbound 内の MessageSource 使用
org.springframework.integration.file.remote 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.file.remote のクラスorg.springframework.integration.file.remote.aop 内の MessageSource 使用
型 MessageSource のパラメーターを持つ org.springframework.integration.file.remote.aop のメソッド修飾子と型メソッド説明@Nullable Message<?>RotatingServerAdvice.afterReceive(@Nullable Message<?> result, MessageSource<?> source) voidRotationPolicy.afterReceive(boolean messageReceived, MessageSource<?> source) メッセージソース receive() メソッドの後に呼び出されます。voidStandardRotationPolicy.afterReceive(boolean messageReceived, MessageSource<?> source) booleanRotatingServerAdvice.beforeReceive(MessageSource<?> source) voidRotationPolicy.beforeReceive(MessageSource<?> source) メッセージソース receive() メソッドの前に呼び出されます。voidStandardRotationPolicy.beforeReceive(MessageSource<?> source) protected voidStandardRotationPolicy.configureSource(MessageSource<?> source) protected voidStandardRotationPolicy.onRotation(MessageSource<?> source) 必要に応じて、サーバーのローテーション後にMessageSourceの状態を更新します。org.springframework.integration.file.remote.synchronizer 内の MessageSource 使用
修飾子と型クラス説明classFTP アダプターと SFTP アダプター間の共通ロジックを除外します。org.springframework.integration.ftp.config 内の MessageSource 使用
型 MessageSource の引数を持つ型を返す org.springframework.integration.ftp.config のメソッド修飾子と型メソッド説明protected ClassSE<? extends MessageSource<?>>FtpStreamingInboundChannelAdapterParser.getMessageSourceClass()org.springframework.integration.ftp.inbound 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.ftp.inbound のクラスorg.springframework.integration.graph 内の MessageSource 使用
型 MessageSource のパラメーターを持つ org.springframework.integration.graph のコンストラクター修飾子コンストラクター説明MessageSourceNode(int nodeId, StringSE name, MessageSource<?> messageSource, StringSE output, @Nullable StringSE errors) org.springframework.integration.hazelcast.inbound 内の MessageSource 使用
修飾子と型クラス説明classHazelcast 分散 SQL メッセージソースは、クラスター内で定義された分散クエリを実行し、反復型に照らして結果を返すメッセージソースです。org.springframework.integration.jdbc.inbound 内の MessageSource 使用
修飾子と型クラス説明class選択クエリを実行して返されたペイロードからメッセージを作成するポーリングチャネルアダプター。classストアドプロシージャまたは SQL 関数を実行して返されたペイロードからメッセージを作成するポーリングチャネルアダプター。org.springframework.integration.jms.inbound 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.jms.inbound のクラスorg.springframework.integration.jmx.inbound 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.jmx.inbound のクラス修飾子と型クラス説明classAbstractMessageSource.receive()が呼び出されるたびに JMX 属性の現在の値を取得するMessageSource実装。classMBean ツリーのフィルタリングされたサブセットのスナップショットを取得するMessageSource実装。org.springframework.integration.jpa.inbound 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.jpa.inbound のクラス修飾子と型クラス説明class提供された結果からメッセージを生成するポーリングメッセージソース: entityClass、JpQl、Select Query、Sql Native Query、JpQl、Named Query、Sql Native Named Query。org.springframework.integration.kafka.inbound 内の MessageSource 使用
org.springframework.integration.mail.inbound 内の MessageSource 使用
org.springframework.integration.mongodb.inbound 内の MessageSource 使用
org.springframework.integration.r2dbc.inbound 内の MessageSource 使用
org.springframework.integration.redis.inbound 内の MessageSource 使用
org.springframework.integration.resource 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.resource のクラス修飾子と型クラス説明classorg.springframework.integration.scripting 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.scripting のクラス修飾子と型クラス説明classエンドポイントをポーリングするために、基盤となる ScriptExecutingMessageSource.scriptMessageProcessor からMessageを生成するためのMessageSource戦略の実装。org.springframework.integration.scripting.dsl 内の MessageSource 使用
org.springframework.integration.sftp.config 内の MessageSource 使用
型 MessageSource の引数を持つ型を返す org.springframework.integration.sftp.config のメソッド修飾子と型メソッド説明protected ClassSE<? extends MessageSource<?>>SftpStreamingInboundChannelAdapterParser.getMessageSourceClass()org.springframework.integration.sftp.inbound 内の MessageSource 使用
修飾子と型クラス説明classInboundFileSynchronizer に委譲する SFTP のMessageSource実装。classSFTP リモートファイルのコンテンツをストリーミングするためのメッセージソース。org.springframework.integration.smb.config 内の MessageSource 使用
型 MessageSource の引数を持つ型を返す org.springframework.integration.smb.config のメソッド修飾子と型メソッド説明protected ClassSE<? extends MessageSource<?>>SmbStreamingInboundChannelAdapterParser.getMessageSourceClass()org.springframework.integration.smb.inbound 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.smb.inbound のクラスorg.springframework.integration.stream.inbound 内の MessageSource 使用
org.springframework.integration.test.context 内の MessageSource 使用
型 MessageSource のパラメーターを持つ org.springframework.integration.test.context のメソッド修飾子と型メソッド説明voidMockIntegrationContext.substituteMessageSourceFor(StringSE pollingAdapterId, MessageSource<?> mockMessageSource) voidMockIntegrationContext.substituteMessageSourceFor(StringSE pollingAdapterId, MessageSource<?> mockMessageSource, boolean autoStartup) org.springframework.integration.test.mock 内の MessageSource 使用
修飾子と型メソッド説明static MessageSource<?>MockIntegration.mockMessageSource(Message<?> message) 提供されたメッセージに基づいて、MessageSourceのモックを作成します。static MessageSource<?>MockIntegration.mockMessageSource(Message<?> message, Message<?> @Nullable... messages) 提供されたメッセージに基づいて、MessageSourceのモックを作成します。static <T> MessageSource<T>MockIntegration.mockMessageSource(T payload) 提供されたペイロードに基づいて、MessageSourceのモックを構築します。static <T> MessageSource<T>MockIntegration.mockMessageSource(T payload, T... payloads) 提供されたペイロードに基づいて、MessageSourceのモックを構築します。org.springframework.integration.util 内の MessageSource 使用
型 MessageSource のパラメーターを持つ org.springframework.integration.util のメソッド修飾子と型メソッド説明static <T> reactor.core.publisher.Flux<Message<T>>IntegrationReactiveUtils.messageSourceToFlux(MessageSource<T> messageSource) 提供されたMessageSourceをFluxにラップして、オンデマンドでメッセージをプルします。