インターフェースの使用
org.springframework.integration.core.MessageSource
MessageSource を使用するパッケージ
パッケージ
説明
メッセージ集約に関連するクラスを提供します。
受信エンドポイントをサポートするクラスを提供します。
AOP を使用したメッセージ公開をサポートするクラスを提供します。
構成の基本パッケージ。
Spring Integration Java DSL のルートパッケージ。
エンドポイントに関連するコアクラスを提供します。
受信エンドポイントをサポートするクラスを提供します。
ファイルサポートの基本パッケージ。
構成用のクラスを提供します。パーサー、名前空間ハンドラー、ファクトリ Bean。
リモートファイルをサポートするための基本パッケージ。
AOP に関連するクラスを提供します。
リモートとローカルファイルディレクトリの同期をサポートするクラスを提供します。
構成用のクラス（パーサー、名前空間ハンドラー）を提供します。
受信エンドポイントをサポートするクラスを提供します。
ランタイムオブジェクトグラフに関連するクラスを提供します。
受信エンドポイントをサポートするクラスを提供します。
Spring Integration JDBC モジュールのルートパッケージ。さまざまな 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 のメソッド修飾子と型メソッド説明Message<?>CompoundTriggerAdvice.afterReceive(Message<?> result, MessageSource<?> source) Message<?>MessageSourceMutator.afterReceive(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, 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, 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 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.file のクラスorg.springframework.integration.file.config 内の MessageSource 使用
型 MessageSource の引数を持つ型を返す org.springframework.integration.file.config のメソッド修飾子と型メソッド説明protected abstract ClassSE<? extends MessageSource<?>>AbstractRemoteFileStreamingInboundChannelAdapterParser.getMessageSourceClass()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 のメソッド修飾子と型メソッド説明Message<?>RotatingServerAdvice.afterReceive(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, StringSE errors) org.springframework.integration.hazelcast.inbound 内の MessageSource 使用
修飾子と型クラス説明classHazelcast 分散 SQL メッセージソースは、クラスター内で定義された分散クエリを実行し、反復型に照らして結果を返すメッセージソースです。org.springframework.integration.jdbc 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.jdbc のクラス修飾子と型クラス説明class選択クエリを実行して返されたペイロードからメッセージを作成するポーリングチャネルアダプター。classストアドプロシージャまたは SQL 関数を実行して返されたペイロードからメッセージを作成するポーリングチャネルアダプター。org.springframework.integration.jms 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.jms のクラスorg.springframework.integration.jmx 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.jmx のクラス修飾子と型クラス説明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 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.mail のクラス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 内の MessageSource 使用
MessageSource を実装している org.springframework.integration.stream のクラス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<?>... 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にラップします。