メソッドの詳細

• from

  public static IntegrationFlowBuilder from(StringSE messageChannelName)

  MessageChannel 名を新しい IntegrationFlowBuilder チェーンに入力します。IntegrationFlow inputChannel。

  パラメーター:

  messageChannelName - 既存の MessageChannel Bean の名前。この名前の Bean がない場合、新しい DirectChannel Bean はコンテキストの起動時に作成されます。

  戻り値:

  新しい IntegrationFlowBuilder。

• from

  public static IntegrationFlowBuilder from(StringSE messageChannelName,
                                            boolean fixedSubscriber)

  MessageChannel 名を新しい IntegrationFlowBuilder チェーンに入力します。通常、FixedSubscriberChannel と fixedSubscriber = true の場合。IntegrationFlow inputChannel。

  パラメーター:

  messageChannelName - 参照ではなく、コンテキストの起動時に作成される DirectChannel または FixedSubscriberChannel の名前。MessageChannel は、fixedSubscriber ブール引数に依存します。

  fixedSubscriber - 結果 MessageChannel が DirectChannel（false の場合）または FixedSubscriberChannel（true の場合）であるかどうかを判別するためのブールフラグ。

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  DirectChannel, FixedSubscriberChannel

• from

  public static IntegrationFlowBuilder from(MessageChannelSpec<?,?> messageChannelSpec)

  MessageChannelSpec の流れるような API を使用して、MessageChannel オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow inputChannel。

  パラメーター:

  messageChannelSpec - MessageChannelSpec を使用して MessageChannel インスタンスを作成します。

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  MessageChannels

• from

  public static IntegrationFlowBuilder from(MessageChannel messageChannel)

  提供された MessageChannel オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow inputChannel。

  パラメーター:

  messageChannel - 投入する MessageChannel

  戻り値:

  新しい IntegrationFlowBuilder。

• from

  public static IntegrationFlowBuilder from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec)

  提供された MessageSourceSpec からの流れるような API を使用して、MessageSource オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessageSource。

  パラメーター:

  messageSourceSpec - 使用する MessageSourceSpec。

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  and its implementations.

• from

  public static IntegrationFlowBuilder from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec,
                                            java.util.function.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)

  提供された MessageSourceSpec からの流れるような API を使用して、MessageSource オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessageSource。

  パラメーター:

  messageSourceSpec - 使用する MessageSourceSpec。

  endpointConfigurer - ConsumerSE は、SourcePollingChannelAdapterFactoryBean により多くのオプションを提供します。

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  MessageSourceSpec, SourcePollingChannelAdapterSpec

• fromSupplier

  public static <T> IntegrationFlowBuilder fromSupplier(java.util.function.SupplierSE<T> messageSource)

  アプリケーションコンテキストのデフォルトのポーラー（宣言する必要があります）によってトリガーされる統合フローへのメッセージのソースとして SupplierSE を提供します。

  型パラメーター:

  T - サプライヤー型。

  パラメーター:

  messageSource - 投入する SupplierSE

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  SupplierSE

• fromSupplier

  public static <T> IntegrationFlowBuilder fromSupplier(java.util.function.SupplierSE<T> messageSource,
                                                        java.util.function.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)

  統合フローへのメッセージのソースとして SupplierSE を提供します。これは、 提供された SourcePollingChannelAdapter によってトリガーされます。

  型パラメーター:

  T - サプライヤー型。

  パラメーター:

  messageSource - 投入する SupplierSE

  endpointConfigurer - ConsumerSE は、SourcePollingChannelAdapterFactoryBean により多くのオプションを提供します。

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  SupplierSE

• from

  public static IntegrationFlowBuilder from(MessageSource<?> messageSource)

  提供された MessageSource オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessageSource。

  パラメーター:

  messageSource - 投入する MessageSource

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  MessageSource

• from

  public static IntegrationFlowBuilder from(MessageSource<?> messageSource,
                                            @Nullable
                                            java.util.function.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)

  提供された MessageSource オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessageSource。さらに、SourcePollingChannelAdapterSpec を使用して、基礎となる SourcePollingChannelAdapter エンドポイントのオプションを提供します。

  パラメーター:

  messageSource - 投入する MessageSource

  endpointConfigurer - ConsumerSE は、SourcePollingChannelAdapterFactoryBean により多くのオプションを提供します。

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  MessageSource, SourcePollingChannelAdapterSpec

• from

  public static IntegrationFlowBuilder from(MessageProducerSpec<?,?> messageProducerSpec)

  MessageProducerSpec からの流れるような API を使用して、MessageProducerSupport オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessageProducer。

  パラメーター:

  messageProducerSpec - 使用する MessageProducerSpec。

  戻り値:

  新しい IntegrationFlowBuilder。

  関連事項:

  MessageProducerSpec

• from

  public static IntegrationFlowBuilder from(MessageProducerSupport messageProducer)

  提供された MessageProducerSupport オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessageProducer。

  パラメーター:

  messageProducer - 投入する MessageProducerSupport

  戻り値:

  新しい IntegrationFlowBuilder。

• from

  public static IntegrationFlowBuilder from(MessagingGatewaySpec<?,?> inboundGatewaySpec)

  MessagingGatewaySpec からの流れるような API を使用して、MessagingGatewaySupport オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessagingGateway。

  パラメーター:

  inboundGatewaySpec - 使用する MessagingGatewaySpec。

  戻り値:

  新しい IntegrationFlowBuilder。

• from

  public static IntegrationFlowBuilder from(MessagingGatewaySupport inboundGateway)

  提供された MessagingGatewaySupport オブジェクトを IntegrationFlowBuilder チェーンに移入します。IntegrationFlow startMessageProducer。

  パラメーター:

  inboundGateway - 投入する MessagingGatewaySupport

  戻り値:

  新しい IntegrationFlowBuilder。

• from

  public static IntegrationFlowBuilder from(ClassSE<?> serviceInterface)

  MessageChannel を新しい IntegrationFlowBuilder チェーンに入力します。これは、提供されたサービスインターフェース上に構築されたメッセージングゲートウェイの requestChannel になります。

  提供されたサービスインターフェースのゲートウェイプロキシ Bean は、存在する場合は MessagingGateway.name() から、または IntegrationFlow からの名前で登録されます。Bean 名と .gateway サフィックス。

  パラメーター:

  serviceInterface - オプションの MessagingGateway アノテーション付きのサービスインターフェースクラス。

  戻り値:

  新しい IntegrationFlowBuilder。

• from

  public static IntegrationFlowBuilder from(ClassSE<?> serviceInterface,
                                            @Nullable
                                            java.util.function.ConsumerSE<GatewayProxySpec> endpointConfigurer)

  MessageChannel を新しい IntegrationFlowBuilder チェーンに入力します。これは、提供されたサービスインターフェース上に構築されたメッセージングゲートウェイの requestChannel になります。

  提供されたサービスインターフェースのゲートウェイプロキシ Bean は、提供された ConsumerSE を介して構成されたオプションに基づいています。

  パラメーター:

  serviceInterface - オプションの MessagingGateway アノテーション付きのサービスインターフェースクラス。

  endpointConfigurer - ゲートウェイのプロキシ Bean を構成するための ConsumerSE。

  戻り値:

  新しい IntegrationFlowBuilder。

  導入:

  5.2

• from

  public static IntegrationFlowBuilder from(org.reactivestreams.Publisher<? extends Message<?>> publisher)

  FluxMessageChannel を IntegrationFlowBuilder チェーンに入力し、提供された Publisher にサブスクライブします。

  パラメーター:

  publisher - サブスクライブする Publisher。

  戻り値:

  新しい IntegrationFlowBuilder。