クラス BaseIntegrationFlowDefinition<B extends BaseIntegrationFlowDefinition<B>>

メソッドの詳細

• addComponent

  protected B addComponent(ObjectSE component)

• addComponent

  protected B addComponent(ObjectSE component, @Nullable StringSE beanName)

• addComponents

  protected B addComponents(MapSE<ObjectSE, @Nullable StringSE> components)

• getIntegrationComponents

  protected MapSE<ObjectSE, @Nullable StringSE> getIntegrationComponents()

• currentComponent

  protected B currentComponent(@Nullable ObjectSE component)

• getCurrentComponent

  protected @Nullable ObjectSE getCurrentComponent()

• currentMessageChannel

  protected B currentMessageChannel(@Nullable MessageChannel currentMessageChannel)

• getCurrentMessageChannel

  protected @Nullable MessageChannel getCurrentMessageChannel()

• currentInterceptableChannel

  protected InterceptableChannel currentInterceptableChannel()

  InterceptableChannel の場合は現在のチャネルを返し、そうでない場合はフローに新しい暗黙の DirectChannel を登録してそのチャネルを返します。

  戻り値:

  操作後の現在のチャネル

• setImplicitChannel

  protected void setImplicitChannel(boolean implicitChannel)

• isImplicitChannel

  protected boolean isImplicitChannel()

• fixedSubscriberChannel

  public B fixedSubscriberChannel()

  現在の IntegrationFlow チェーン位置に FixedSubscriberChannel インスタンスを生成します。「Bean 名」は、Bean 登録フェーズ中に生成されます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• fixedSubscriberChannel

  public B fixedSubscriberChannel(@Nullable StringSE messageChannelName)

  現在の IntegrationFlow チェーンの位置に FixedSubscriberChannel インスタンスを入力します。提供された messageChannelName は、Bean 登録に使用されます。

  パラメーター:

  messageChannelName - 使用する Bean 名。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• channel

  public B channel(StringSE messageChannelName)

  現在の IntegrationFlow チェーン位置に MessageChannelReference インスタンスを設定します。アプリケーションコンテキストにそのような Bean が存在しない場合、提供された messageChannelName は Bean 登録 ( DirectChannel ) に使用されます。それ以外の場合は、既存の MessageChannel Bean を使用して統合エンドポイントを接続します。

  パラメーター:

  messageChannelName - 使用する Bean 名。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• channel

  public B channel(MessageChannelSpec<?,?> messageChannelSpec)

  MessageChannelSpec Fluent API を使用して、現在の IntegrationFlow チェーン位置に MessageChannel インスタンスを生成します。

  パラメーター:

  messageChannelSpec - 使用する MessageChannelSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MessageChannels

• channel

  public B channel(MessageChannel messageChannel)

  提供された MessageChannel インスタンスを現在の IntegrationFlow チェーン位置に入力します。messageChannel は、既存の Bean または新規インスタンスにすることができます。その場合、IntegrationFlowBeanPostProcessor は、生成された名前で Bean としてそれを生成します。

  パラメーター:

  messageChannel - 投入する MessageChannel

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• channel

  public B channel(FunctionSE<Channels, MessageChannelSpec<?,?>> channels)

  Channels ファクトリ Fluent API を使用して、現在の IntegrationFlow チェーン位置に MessageChannel インスタンスを生成します。

  パラメーター:

  channels - 使用する FunctionSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• publishSubscribeChannel

  public B publishSubscribeChannel(ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)

  PublishSubscribeChannel channel(java.lang.String) メソッド固有の実装。「サブフロー」サブスクライバー機能の使用を許可します。

  パラメーター:

  publishSubscribeChannelConfigurer - ConsumerSE は、「サブフロー」定義を含む PublishSubscribeSpec オプションを指定します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• publishSubscribeChannel

  public B publishSubscribeChannel(@Nullable ExecutorSE executor, ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)

  「サブフロー」サブスクライバー機能の使用を可能にする PublishSubscribeChannel channel(java.lang.String) メソッド固有の実装。ターゲットサブスクライバーには、提供されている ExecutorSE を使用します。

  パラメーター:

  executor - 使用する ExecutorSE。

  publishSubscribeChannelConfigurer - ConsumerSE は、「サブフロー」定義を含む PublishSubscribeSpec オプションを指定します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• publishSubscribeChannel

  public B publishSubscribeChannel(BroadcastCapableChannel broadcastCapableChannel, ConsumerSE<BroadcastPublishSubscribeSpec> publishSubscribeChannelConfigurer)

  BroadcastCapableChannel channel(java.lang.String) メソッド固有の実装。「サブフロー」サブスクライバー機能の使用を許可します。

  パラメーター:

  broadcastCapableChannel - BroadcastCapableChannel からサブスクライバーへのサブフロー。

  publishSubscribeChannelConfigurer - BroadcastPublishSubscribeSpec の「サブフロー」定義を指定する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  5.3

• wireTap

  public B wireTap(IntegrationFlow flow)

  Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙的な MessageChannel が使用されている場合に役立ちます。

   
    .filter("World"::equals)
    .wireTap(sf -> sf.<String, String>transform(String::toUpperCase))
    .handle(p -> process(p))
   
   

  このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。

  パラメーター:

  flow - wireTapChannel の代替としての、ワイヤータップサブフロー用の IntegrationFlow

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• wireTap

  public B wireTap(StringSE wireTapChannel)

  Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙的な MessageChannel が使用されている場合に役立ちます。

   
    f -> f.wireTap("tapChannel")
      .handle(p -> process(p))
   
   

  このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。

  パラメーター:

  wireTapChannel - 盗聴する MessageChannel Bean の名前。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• wireTap

  public B wireTap(MessageChannel wireTapChannel)

  Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙的な MessageChannel が使用されている場合に役立ちます。

   
    .transform("payload")
    .wireTap(tapChannel())
    .channel("foo")
   
   

  このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。

  パラメーター:

  wireTapChannel - ワイヤータップする MessageChannel

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• wireTap

  public B wireTap(IntegrationFlow flow, @Nullable ConsumerSE<WireTapSpec> wireTapConfigurer)

  Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙的な MessageChannel が使用されている場合に役立ちます。

   
    .transform("payload")
    .wireTap(sf -> sf.<String, String>transform(String::toUpperCase), wt -> wt.selector("payload == 'foo'"))
    .channel("foo")
   
   

  このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。

  パラメーター:

  flow - wireTapChannel の代替としての、ワイヤータップサブフロー用の IntegrationFlow

  wireTapConfigurer - WireTap のオプションを受け入れる ConsumerSE

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• obtainInputChannelFromFlow

  protected MessageChannel obtainInputChannelFromFlow(IntegrationFlow flow)

• wireTap

  public B wireTap(StringSE wireTapChannel, @Nullable ConsumerSE<WireTapSpec> wireTapConfigurer)

  Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙的な MessageChannel が使用されている場合に役立ちます。

   
    .transform("payload")
    .wireTap("tapChannel", wt -> wt.selector(m -> m.getPayload().equals("foo")))
    .channel("foo")
   
   

  このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。

  パラメーター:

  wireTapChannel - 盗聴する MessageChannel Bean の名前。

  wireTapConfigurer - WireTap のオプションを受け入れる ConsumerSE

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• wireTap

  public B wireTap(MessageChannel wireTapChannel, @Nullable ConsumerSE<WireTapSpec> wireTapConfigurer)

  Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙的な MessageChannel が使用されている場合に役立ちます。

   
    .transform("payload")
    .wireTap(tapChannel(), wt -> wt.selector(m -> m.getPayload().equals("foo")))
    .channel("foo")
   
   

  このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。

  パラメーター:

  wireTapChannel - ワイヤータップする MessageChannel

  wireTapConfigurer - WireTap のオプションを受け入れる ConsumerSE

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• wireTap

  public B wireTap(WireTapSpec wireTapSpec)

  Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。

  エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。

   
    .transform("payload")
    .wireTap(new WireTap(tapChannel()).selector(m -> m.getPayload().equals("foo")))
    .channel("foo")
   
   

  このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。

  パラメーター:

  wireTapSpec - 使用する WireTapSpec。

  この EIP メソッドがフローの最後で使用される場合、フローを適切に終了するために nullChannel が追加されます。それ以外の場合は、暗黙的な DirectChannel に対して Dispatcher has no subscribers 例外がスローされます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• controlBus

  public B controlBus()

  Control Bus EI パターン固有の MessageHandler 実装を現在の IntegrationFlow チェーン位置に入力します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• controlBus

  public B controlBus(@Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

  Control Bus EI パターン固有の MessageHandler 実装を現在の IntegrationFlow チェーン位置に入力します。

  パラメーター:

  endpointConfigurer - 統合エンドポイントオプションを受け入れる ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • GenericEndpointSpec

• transform

  public B transform(StringSE expression)

  SpEL Expression の Transformer EI パターン固有の MessageHandler 実装を設定します。ショートカット:

   
    .transformWith((transformerSpec) -> transformerSpec.expression(expression))
   
   

  パラメーター:

  expression - Transformer Expression

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • ExpressionEvaluatingTransformer

• transform

  public B transform(ObjectSE service)

  検出されたサービスメソッドを実行時に呼び出すために、MethodInvokingTransformer の MessageTransformingHandler を設定します。ショートカット:

   
    .transformWith((transformerSpec) -> transformerSpec.ref(service))
   
   

  パラメーター:

  service - 使用するサービス。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingTransformer

• transform

  public B transform(ObjectSE service, @Nullable StringSE methodName)

  MethodInvokingTransformer の MessageTransformingHandler を設定して、実行時にサービスメソッドを呼び出します。

   
    .transformWith((transformerSpec) -> transformerSpec.ref(service).method(methodName))
   
   

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingTransformer

• transform

  public B transform(StringSE beanName, @Nullable StringSE methodName)

  実行時に Bean メソッドを呼び出すために、MethodInvokingTransformer の MessageTransformingHandler を設定します。

   
    .transformWith((transformerSpec) -> transformerSpec.refName(beanName).method(methodName))
   
   

  パラメーター:

  beanName - 遅延解決する Bean の名前。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  6.2

  関連事項:

  • MethodInvokingTransformer

• transform

  public B transform(MessageProcessorSpec<?> messageProcessorSpec)

  提供された MessageProcessorSpec から MessageProcessor の MessageTransformingHandler インスタンスを生成します。

   
    .transform(Scripts.script("classpath:myScript.py").variable("foo", bar()))
   
   

  ショートカット:

   
    .transformWith((transformerSpec) -> transformerSpec.processor(messageProcessorSpec))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingTransformer

• convert

  public <P> B convert(ClassSE<P> payloadType)

  提供された payloadType の MessageTransformingHandler インスタンスを生成して、実行時に変換します。

  型パラメーター:

  P - ペイロード型 - ' に変換 '。

  パラメーター:

  payloadType - 予想されるペイロード型の ClassSE

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  5.1

  関連事項:

  • MethodInvokingTransformer
  • LambdaMessageProcessor

• transform

  public <P,T> B transform(ClassSE<P> expectedType, GenericTransformer<P,T> genericTransformer)

  特定の expectedType が実行時に変換するために、提供された GenericTransformer の MessageTransformingHandler インスタンスを生成します。

  型パラメーター:

  P - ペイロード型 - 'transform from' または Message.class。

  T - ターゲット型 - 「変換する」。

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE トランスフォーマー内のメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  genericTransformer - 投入する GenericTransformer

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingTransformer
  • LambdaMessageProcessor

• convert

  public <P> B convert(ClassSE<P> payloadType, ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  提供された payloadType の MessageTransformingHandler インスタンスにデータを入力して、実行時に変換します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  型パラメーター:

  P - ペイロード型 - 「変換する」。

  パラメーター:

  payloadType - 予想されるペイロード型の ClassSE

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  5.1

  関連事項:

  • MethodInvokingTransformer
  • LambdaMessageProcessor
  • GenericEndpointSpec

• transformWith

  public B transformWith(ConsumerSE<TransformerEndpointSpec> transformerConfigurer)

  指定された TransformerEndpointSpec オプションを使用して、エンドポイントに MessageTransformingHandler を入力します。"expression"、"ref"、"refName"、"processor"、"function" のいずれかを指定する必要があります。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  6.2

• filter

  public B filter(StringSE expression)

  指定された SpEL 式の MessageFilter に MessageSelector を入力します。

  パラメーター:

  expression - SpEL 式。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• filter

  public B filter(StringSE expression, @Nullable ConsumerSE<FilterEndpointSpec> endpointConfigurer)

  指定された SpEL 式の MessageSelector を使用して MessageFilter を設定します。さらに、FilterEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

   
    .filter("payload.hot"), e -> e.autoStartup(false))
   
   

  パラメーター:

  expression - SpEL 式。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • FilterEndpointSpec

• filter

  public B filter(ObjectSE service)

  提供されたサービスの検出されたメソッドのために、MessageFilter に MethodInvokingSelector を取り込みます。

  パラメーター:

  service - 使用するサービス。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingSelector

• filter

  public B filter(ObjectSE service, @Nullable StringSE methodName)

  提供されたサービスのメソッドのために、MessageFilter に MethodInvokingSelector を取り込みます。

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingSelector

• filter

  public B filter(ObjectSE service, @Nullable StringSE methodName, @Nullable ConsumerSE<FilterEndpointSpec> endpointConfigurer)

  提供されたサービスのメソッドのために、MessageFilter に MethodInvokingSelector を取り込みます。

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingSelector

• filter

  public B filter(MessageProcessorSpec<?> messageProcessorSpec)

  MessageFilter に、提供された MessageProcessorSpec から MessageProcessor の MethodInvokingSelector を取り込みます。

   
    .filter(Scripts.script(scriptResource).lang("ruby"))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• filter

  public B filter(MessageProcessorSpec<?> messageProcessorSpec, @Nullable ConsumerSE<FilterEndpointSpec> endpointConfigurer)

  提供された MessageProcessorSpec から MessageProcessor の MethodInvokingSelector を MessageFilter に取り込みます。さらに、FilterEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

   
    .filter(Scripts.script(scriptResource).lang("ruby"),
          e -> e.autoStartup(false))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• filter

  public <P> B filter(ClassSE<P> expectedType, GenericSelector<P> genericSelector)

  提供された GenericSelector に対して MessageFilter に MethodInvokingSelector を入力します。通常、Java 8 ラムダ式で使用されます。

   
    .filter(Date.class, p -> p.after(new Date()))
   
   

  型パラメーター:

  P - ソースのペイロード型または Message.class

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE セレクターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  genericSelector - 使用する GenericSelector。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor

• filter

  public <P> B filter(ClassSE<P> expectedType, GenericSelector<P> genericSelector, @Nullable ConsumerSE<FilterEndpointSpec> endpointConfigurer)

  提供された GenericSelector に対して MessageFilter に MethodInvokingSelector を入力します。さらに、FilterEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。

   
    .filter(Date.class, p -> p.after(new Date()), e -> e.autoStartup(false))
   
   

  型パラメーター:

  P - ソースのペイロード型または Message.class

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE セレクターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  genericSelector - 使用する GenericSelector。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor
  • FilterEndpointSpec

• doFilter

  protected <P> B doFilter(@Nullable ClassSE<P> expectedType, GenericSelector<P> genericSelector, @Nullable ConsumerSE<FilterEndpointSpec> endpointConfigurer)

• handle

  public <H extends MessageHandler> B handle(MessageHandlerSpec<?,H> messageHandlerSpec)

  選択したプロトコル固有の MessageHandler 実装の ServiceActivatingHandler を、それぞれの名前空間ファクトリ (例: Http, Kafka, Files) から設定します。

   
    .handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"))
   
   

  .

  型パラメーター:

  H - ターゲット MessageHandler 型。

  パラメーター:

  messageHandlerSpec - プロトコル固有の MessageHandler を構成する MessageHandlerSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(MessageHandler messageHandler)

  提供された MessageHandler 実装の ServiceActivatingHandler を設定します。ラムダ式として使用できます:

   
    .handle(m -> logger.info(m.getPayload())
   
   

  パラメーター:

  messageHandler - 使用する MessageHandler。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(StringSE beanName, @Nullable StringSE methodName)

  MethodInvokingMessageProcessor の ServiceActivatingHandler を生成して、実行時に提供された bean の method を呼び出します。

  パラメーター:

  beanName - 使用する Bean 名。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(StringSE beanName, @Nullable StringSE methodName, @Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

  MethodInvokingMessageProcessor の ServiceActivatingHandler を設定して、実行時に提供された bean の method を呼び出します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  パラメーター:

  beanName - 使用する Bean 名。

  methodName - 呼び出すメソッド。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(ObjectSE service)

  MethodInvokingMessageProcessor の ServiceActivatingHandler を入力して、実行時に提供された service のディスカバーされた method を呼び出します。

  パラメーター:

  service - 使用するサービスオブジェクト。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(ObjectSE service, @Nullable StringSE methodName)

  MethodInvokingMessageProcessor の ServiceActivatingHandler を設定して、実行時に提供された bean の method を呼び出します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  パラメーター:

  service - 使用するサービスオブジェクト。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(ObjectSE service, @Nullable StringSE methodName, @Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

  MethodInvokingMessageProcessor の ServiceActivatingHandler を設定して、実行時に提供された bean の method を呼び出します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  パラメーター:

  service - 使用するサービスオブジェクト。

  methodName - 呼び出すメソッド。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public <P> B handle(ClassSE<P> expectedType, GenericHandler<P> handler)

  実行時に提供された GenericHandler を呼び出すために、MethodInvokingMessageProcessor の ServiceActivatingHandler を設定します。通常、Lambda 式で使用されます。

   
    .handle(Integer.class, (p, h) -> p / 2)
   
   

  型パラメーター:

  P - 期待するペイロード型、または Message.class。

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE ハンドラーでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  handler - 呼び出すハンドラー。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor

• handle

  public <P> B handle(ClassSE<P> expectedType, GenericHandler<P> handler, @Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

  実行時に提供された GenericHandler を呼び出すために、MethodInvokingMessageProcessor の ServiceActivatingHandler を設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Lambda 式で使用されます。

   
    .handle(Integer.class, (p, h) -> p / 2, e -> e.autoStartup(false))
   
   

  型パラメーター:

  P - 期待するペイロード型または Message.class。

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE ハンドラーでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  handler - 呼び出すハンドラー。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor

• doHandle

  protected <P> B doHandle(@Nullable ClassSE<P> expectedType, GenericHandler<P> handler, @Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

• handle

  public B handle(MessageProcessorSpec<?> messageProcessorSpec)

  提供された MessageProcessorSpec から MessageProcessor の ServiceActivatingHandler を生成します。

   
    .handle(Scripts.script("classpath:myScript.ruby"))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(MessageProcessorSpec<?> messageProcessorSpec, @Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

  提供された MessageProcessorSpec から MessageProcessor の ServiceActivatingHandler を設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

   
    .handle(Scripts.script("classpath:myScript.ruby"), e -> e.autoStartup(false))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public <H extends MessageHandler> B handle(MessageHandlerSpec<?,H> messageHandlerSpec, @Nullable ConsumerSE<GenericEndpointSpec<H>> endpointConfigurer)

  選択したプロトコル固有の MessageHandler 実装の ServiceActivatingHandler を、それぞれの名前空間ファクトリ (例: Http, Kafka, Files) から設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、ラムダ式で使用されます。

   
    .handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"),
         e -> e.autoStartup(false))
   
   

  型パラメーター:

  H - MessageHandler 型。

  パラメーター:

  messageHandlerSpec - プロトコル固有の MessageHandler を構成する MessageHandlerSpec。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public <H extends MessageHandler> B handle(H messageHandler, @Nullable ConsumerSE<GenericEndpointSpec<H>> endpointConfigurer)

  提供された MessageHandler 実装の ServiceActivatingHandler を設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。ラムダ式として使用できます:

   
    .handle(m -> logger.info(m.getPayload()), e -> e.autoStartup(false))
   
   

  型パラメーター:

  H - MessageHandler 型。

  パラメーター:

  messageHandler - 使用する MessageHandler。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• bridge

  public B bridge()

  BridgeHandler を現在の統合フロー位置に取り込みます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • bridge(Consumer)

• bridge

  public B bridge(@Nullable ConsumerSE<GenericEndpointSpec<BridgeHandler>> endpointConfigurer)

  BridgeHandler を現在の統合フロー位置に設定します。通常、Lambda 式で使用されます。

   
    .bridge(s -> s.poller(Pollers.fixedDelay(100))
                     .autoStartup(false)
                     .id("priorityChannelBridge"))
   
   

  パラメーター:

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • GenericEndpointSpec

• delay

  public B delay(StringSE groupId)

  デフォルトのオプションを使用して、現在の統合フロー位置に DelayHandler を設定します。ショートカット:

   
    .delay(delayer -> delayer.messageGroupId(groupId))
   
   

  パラメーター:

  groupId - MessageGroupStore の遅延メッセージの groupId 

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• delay

  public B delay(ConsumerSE<DelayerEndpointSpec> endpointConfigurer)

  DelayHandler を現在の積分フロー位置に配置します。DelayerEndpointSpec.messageGroupId(String) は必須オプションです。

  パラメーター:

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  6.2

  関連事項:

  • DelayerEndpointSpec

• enrich

  public B enrich(ConsumerSE<EnricherSpec> enricherConfigurer)

  提供されたオプションを使用して、現在の統合フロー位置に ContentEnricher を設定します。通常、Lambda 式で使用されます。

   
    .enrich(e -> e.requestChannel("enrichChannel")
                    .requestPayload(Message::getPayload)
                    .shouldClonePayload(false)
                    .autoStartup(false)
                    .<Map<String, String>>headerFunction("foo", m -> m.getPayload().get("name")))
   
   

  パラメーター:

  enricherConfigurer - ContentEnricher オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • EnricherSpec

• enrichHeaders

  public B enrichHeaders(MapBuilder<?,StringSE,ObjectSE> headers)

  提供された MapBuilder のヘッダー値を使用して、HeaderEnricher の MessageTransformingHandler を設定します。名前空間ファクトリと一緒に使用できます。

   
    .enrichHeaders(Mail.headers()
                      .subjectFunction(m -> "foo")
                      .from("foo@bar")
                      .toFunction(m -> new String[] {"bar@baz"}))
   
   

  パラメーター:

  headers - 使用する MapBuilder。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• enrichHeaders

  public B enrichHeaders(MapBuilder<?,StringSE,ObjectSE> headers, @Nullable ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  提供された MapBuilder のヘッダー値を使用して、HeaderEnricher の MessageTransformingHandler を設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。名前空間ファクトリと一緒に使用できます。

   
    .enrichHeaders(Mail.headers()
                      .subjectFunction(m -> "foo")
                      .from("foo@bar")
                      .toFunction(m -> new String[] {"bar@baz"}),
                   e -> e.autoStartup(false))
   
   

  パラメーター:

  headers - 使用する MapBuilder。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • GenericEndpointSpec

• enrichHeaders

  public B enrichHeaders(MapSE<StringSE,ObjectSE> headers)

  Message ヘッダーエンリッチメントに使用される値の MapSE を受け入れます。values は、リクエスト Message に対して評価される Expression を適用できます。

  パラメーター:

  headers - エンリッチするヘッダーのマップ。

  戻り値:

  現在の IntegrationFlowDefinition。

• enrichHeaders

  public B enrichHeaders(MapSE<StringSE,ObjectSE> headers, @Nullable ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  Message ヘッダーエンリッチメントに使用される値の MapSE を受け入れます。values は、リクエスト Message に対して評価される Expression を適用できます。

  パラメーター:

  headers - エンリッチするヘッダーのマップ。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • GenericEndpointSpec

• enrichHeaders

  public B enrichHeaders(ConsumerSE<HeaderEnricherSpec> headerEnricherConfigurer)

  提供された ConsumerSE の結果として、HeaderEnricher の MessageTransformingHandler を設定します。通常、Lambda 式で使用されます。

   
    .enrichHeaders(h -> h.header(FileHeaders.FILENAME, "foo.sitest")
                         .header("directory", new File(tmpDir, "fileWritingFlow")))
   
   

  パラメーター:

  headerEnricherConfigurer - 使用する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • HeaderEnricherSpec

• split

  public B split()

  DefaultMessageSplitter に現在の統合フロー位置のデフォルトオプションを入力します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• splitWith

  public B splitWith(ConsumerSE<SplitterSpec> splitterConfigurer)

  提供されたオプションをスプリッターに現在の統合フロー位置に設定します。

   
    .splitWith(s -> s.applySequence(false).delimiters(","))
   
   

  または、POJO サービスメソッド呼び出しへの参照を使用します。

   
    .splitWith(s -> s.ref("someService").method("someMethod"))
   
   

  パラメーター:

  splitterConfigurer - オプションスプリッタエンドポイントを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  6.2

  関連事項:

  • SplitterSpec

• split

  public B split(StringSE expression)

  提供された SpEL 式を ExpressionEvaluatingSplitter に入力します。

  パラメーター:

  expression - スプリッター SpEL 式。ExpressionEvaluatingSplitter の場合。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • SplitterSpec

• split

  public B split(ObjectSE service)

  MethodInvokingSplitter にデータを入力して、実行時に service の検出された method を評価します。

  パラメーター:

  service - 使用するサービス。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingSplitter

• split

  public B split(ObjectSE service, @Nullable StringSE methodName)

  実行時に service の提供された method を評価するために MethodInvokingSplitter を入力します。

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingSplitter

• split

  public B split(StringSE beanName, @Nullable StringSE methodName)

  実行時に bean の提供された method を評価するために MethodInvokingSplitter を入力します。

  パラメーター:

  beanName - 使用する Bean 名。

  methodName - 実行時に呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• split

  public B split(MessageProcessorSpec<?> messageProcessorSpec)

  提供された MessageProcessorSpec から実行時に MessageProcessor を評価するために、MethodInvokingSplitter を入力します。

   
    .split(Scripts.script("classpath:myScript.ruby"))
   
   

  パラメーター:

  messageProcessorSpec - スプリッター MessageProcessorSpec

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • SplitterSpec

• split

  public <P> B split(ClassSE<P> expectedType, FunctionSE<P,?> splitter)

  実行時に提供された FunctionSE を評価するために MethodInvokingSplitter を設定します。通常、Lambda 式で使用されます。

   
    .split(String.class, p ->
          jdbcTemplate.execute("SELECT * from FOO",
              (PreparedStatement ps) ->
                   new ResultSetIterator<Foo>(ps.executeQuery(),
                       (rs, rowNum) ->
                             new Foo(rs.getInt(1), rs.getString(2)))))
   
   

  型パラメーター:

  P - ペイロード型または Message.class

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE スプリッターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  splitter - スプリッター FunctionSE

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor

• split

  public <S extends AbstractMessageSplitter> B split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec)

  提供された AbstractMessageSplitter を現在の統合フロー位置に入力します。

  型パラメーター:

  S - AbstractMessageSplitter

  パラメーター:

  splitterMessageHandlerSpec - 投入する MessageHandlerSpec

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • SplitterSpec

• split

  public B split(AbstractMessageSplitter splitter)

  提供された AbstractMessageSplitter を現在の統合フロー位置に入力します。

  パラメーター:

  splitter - 投入する AbstractMessageSplitter

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • SplitterSpec

• headerFilter

  public B headerFilter(StringSE... headersToRemove)

  HeaderFilter を現在の StandardIntegrationFlow に提供します。

  パラメーター:

  headersToRemove - MessageHeaders から削除するヘッダー（またはパターン）の配列。

  戻り値:

  この BaseIntegrationFlowDefinition。

• headerFilter

  public B headerFilter(ConsumerSE<HeaderFilterSpec> headerFilter)

  HeaderFilterSpec の流れるような API を介して HeaderFilter オプションを提供します。

  パラメーター:

  headerFilter - ConsumerSE はヘッダーフィルターとそのエンドポイントオプションを提供します。

  戻り値:

  この BaseIntegrationFlowDefinition。

  導入:

  6.2

• headerFilter

  public B headerFilter(HeaderFilter headerFilter, @Nullable ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  提供された HeaderFilter に提供された MessageTransformingHandler を取り込みます。

  パラメーター:

  headerFilter - 使用する HeaderFilter。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • GenericEndpointSpec

• claimCheckIn

  public B claimCheckIn(MessageStore messageStore)

  ClaimCheckInTransformer の MessageTransformingHandler に提供された MessageStore を入力します。

  パラメーター:

  messageStore - 使用する MessageStore。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• claimCheckIn

  public B claimCheckIn(MessageStore messageStore, @Nullable ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  提供された MessageStore を使用して、ClaimCheckInTransformer の MessageTransformingHandler を設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  パラメーター:

  messageStore - 使用する MessageStore。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • GenericEndpointSpec

• claimCheckOut

  public B claimCheckOut(MessageStore messageStore)

  ClaimCheckOutTransformer の MessageTransformingHandler に、提供されている MessageStore を入力します。ClaimCheckOutTransformer の removeMessage オプションは false に対するものです。

  パラメーター:

  messageStore - 使用する MessageStore。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• claimCheckOut

  public B claimCheckOut(MessageStore messageStore, boolean removeMessage)

  ClaimCheckOutTransformer の MessageTransformingHandler に、提供された MessageStore および removeMessage フラグを取り込みます。

  パラメーター:

  messageStore - 使用する MessageStore。

  removeMessage - removeMessage ブールフラグ。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • ClaimCheckOutTransformer.setRemoveMessage(boolean)

• claimCheckOut

  public B claimCheckOut(MessageStore messageStore, boolean removeMessage, @Nullable ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  提供された MessageStore および removeMessage フラグを使用して、ClaimCheckOutTransformer の MessageTransformingHandler を設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  パラメーター:

  messageStore - 使用する MessageStore。

  removeMessage - removeMessage ブールフラグ。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • GenericEndpointSpec
  • ClaimCheckOutTransformer.setRemoveMessage(boolean)

• resequence

  public B resequence()

  ResequencingMessageHandler にデフォルトオプションを入力します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• resequence

  public B resequence(ConsumerSE<ResequencerSpec> resequencer)

  ResequencerSpec から提供されたオプションを ResequencingMessageHandler に入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Lambda 式で使用されます。

   
    .resequence(r -> r.releasePartialSequences(true)
                      .correlationExpression("'foo'")
                      .phase(100))
   
   

  パラメーター:

  resequencer - ResequencingMessageHandler オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • ResequencerSpec

• aggregate

  public B aggregate()

  AggregatingMessageHandler にデフォルトオプションを入力します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• aggregate

  public B aggregate(ObjectSE aggregatorProcessor)

  aggregate((aggregator) -> aggregator.processor(aggregatorProcessor)) のショートカット。

  パラメーター:

  aggregatorProcessor - 集約戦略を表す POJO。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  5.5

  関連事項:

  • AggregatorSpec

• aggregate

  public B aggregate(ConsumerSE<AggregatorSpec> aggregator)

  AggregatorSpec から提供されたオプションを AggregatingMessageHandler に入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Lambda 式で使用されます。

   
    .aggregate(a -> a.correlationExpression("1")
                     .releaseStrategy(g -> g.size() == 25)
                     .phase(100))
   
   

  パラメーター:

  aggregator - AggregatingMessageHandler オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • AggregatorSpec

• route

  public B route(StringSE beanName, @Nullable StringSE method)

  提供された Bean の MethodInvokingRouter とそのメソッドにデフォルトのオプションを入力します。

  パラメーター:

  beanName - 使用する Bean。

  method - 実行時に呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public B route(StringSE beanName, @Nullable StringSE method, @Nullable ConsumerSE<RouterSpec<@Nullable ObjectSE, MethodInvokingRouter>> routerConfigurer)

  提供された Bean の MethodInvokingRouter と、そのメソッドに RouterSpec の提供されたオプションを入力します。

  パラメーター:

  beanName - 使用する Bean。

  method - 実行時に呼び出すメソッド。

  routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public B route(ObjectSE service)

  提供されたサービスのディスカバーされたメソッドとそのメソッドの MethodInvokingRouter にデフォルトのオプションを入力します。

  パラメーター:

  service - 使用する Bean。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingRouter

• route

  public B route(ObjectSE service, @Nullable StringSE methodName)

  提供されたサービスのメソッドとそのメソッドの MethodInvokingRouter にデフォルトのオプションを入力します。

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingRouter

• route

  public B route(ObjectSE service, @Nullable StringSE methodName, @Nullable ConsumerSE<RouterSpec<@Nullable ObjectSE, MethodInvokingRouter>> routerConfigurer)

  提供されたサービスのメソッドとそのメソッドの MethodInvokingRouter に、RouterSpec から提供されたオプションを入力します。

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

  routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • MethodInvokingRouter

• route

  public B route(StringSE expression)

  提供された SpEL 式の ExpressionEvaluatingRouter にデフォルトオプションを入力します。

  パラメーター:

  expression - 使用する式。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public <T extends @Nullable ObjectSE> B route(StringSE expression, @Nullable ConsumerSE<RouterSpec<T, ExpressionEvaluatingRouter>> routerConfigurer)

  提供された SpEL 式の ExpressionEvaluatingRouter に、RouterSpec から提供されたオプションを入力します。

  型パラメーター:

  T - ターゲットの結果型。

  パラメーター:

  expression - 使用する式。

  routerConfigurer - ExpressionEvaluatingRouter オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public <S, T extends @Nullable ObjectSE> B route(ClassSE<S> expectedType, FunctionSE<S,T> router)

  提供された FunctionSE およびペイロード型の MethodInvokingRouter にデフォルトオプションを入力します。通常、Lambda 式で使用されます。

   
    .route(Integer.class, p -> p % 2 == 0)
   
   

  型パラメーター:

  S - ソースのペイロード型または Message.class

  T - ターゲットの結果型。

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE。ルーター内のメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  router - 使用する FunctionSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor

• route

  public <P, T extends @Nullable ObjectSE> B route(ClassSE<P> expectedType, FunctionSE<P,T> router, @Nullable ConsumerSE<RouterSpec<T, MethodInvokingRouter>> routerConfigurer)

  提供された FunctionSE の MethodInvokingRouter と、RouterSpec からのペイロード型とオプションを入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Lambda 式で使用されます。

   
    .route(Integer.class, p -> p % 2 == 0,
  					m -> m.channelMapping("true", "evenChannel")
                         .subFlowMapping("false", f ->
                                     f.<Integer>handle((p, h) -> p * 3))
                         .applySequence(false))
   
   

  型パラメーター:

  P - ソースのペイロード型または Message.class

  T - ターゲットの結果型。

  パラメーター:

  expectedType - 予想されるペイロード型の ClassSE。ルーター内のメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。

  router - 使用する FunctionSE。

  routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor

• doRoute

  protected <P, T extends @Nullable ObjectSE> B doRoute(@Nullable ClassSE<P> expectedType, FunctionSE<P,T> router, @Nullable ConsumerSE<RouterSpec<T, MethodInvokingRouter>> routerConfigurer)

• route

  public B route(MessageProcessorSpec<?> messageProcessorSpec)

  デフォルトのオプションを使用して、提供されている MessageProcessorSpec から MessageProcessor の MethodInvokingRouter を生成します。

   
    .route(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public B route(MessageProcessorSpec<?> messageProcessorSpec, @Nullable ConsumerSE<RouterSpec<@Nullable ObjectSE, MethodInvokingRouter>> routerConfigurer)

  デフォルトのオプションを使用して、提供されている MessageProcessorSpec から MessageProcessor の MethodInvokingRouter を生成します。

   
    .route(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000),
                   m -> m.channelMapping("true", "evenChannel")
                         .subFlowMapping("false", f ->
                                     f.<Integer>handle((p, h) -> p * 3)))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  protected <R extends AbstractMessageRouter, S extends AbstractRouterSpec<? super S, R>> B route(S routerSpec, @Nullable ConsumerSE<S> routerConfigurer)

• routeToRecipients

  public B routeToRecipients(ConsumerSE<RecipientListRouterSpec> routerConfigurer)

  RecipientListRouter に RecipientListRouterSpec のオプションを設定します。通常、Lambda 式で使用されます。

   
    .routeToRecipients(r -> r
        .recipient("bar-channel", m ->
              m.getHeaders().containsKey("recipient") && (boolean) m.getHeaders().get("recipient"))
        .recipientFlow("'foo' == payload or 'bar' == payload or 'baz' == payload",
                           f -> f.transform(String.class, p -> p.toUpperCase())
                                 .channel(c -> c.queue("recipientListSubFlow1Result"))))
   
   

  パラメーター:

  routerConfigurer - RecipientListRouter オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• routeByException

  public B routeByException(ConsumerSE<RouterSpec<ClassSE<? extends ThrowableSE>, ErrorMessageExceptionTypeRouter>> routerConfigurer)

  ErrorMessageExceptionTypeRouter に RouterSpec のオプションを設定します。通常、Lambda 式で使用されます。

   
    .routeByException(r -> r
        .channelMapping(IllegalArgumentException.class, "illegalArgumentChannel")
        .subFlowMapping(MessageHandlingException.class, sf ->
                                  sf.handle(...))
      )
   
   

  パラメーター:

  routerConfigurer - ErrorMessageExceptionTypeRouter オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • ErrorMessageExceptionTypeRouter

• route

  public B route(AbstractMessageRouter router)

  提供された AbstractMessageRouter 実装を現在の統合フロー位置に取り込みます。

  パラメーター:

  router - 投入する AbstractMessageRouter

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public <R extends AbstractMessageRouter> B route(R router, @Nullable ConsumerSE<GenericEndpointSpec<R>> endpointConfigurer)

  提供された AbstractMessageRouter 実装を現在の統合フロー位置に取り込みます。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  型パラメーター:

  R - AbstractMessageRouter 型。

  パラメーター:

  router - 投入する AbstractMessageRouter

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(StringSE requestChannel)

  提供された requestChannel の「人工的な」GatewayMessageHandler を設定して、デフォルトのオプションでリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。

  パラメーター:

  requestChannel - MessageChannel Bean 名。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(StringSE requestChannel, @Nullable ConsumerSE<GatewayEndpointSpec> endpointConfigurer)

  提供された requestChannel の「人工」GatewayMessageHandler にデータを入力して、GatewayEndpointSpec のオプションを含むリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。

  パラメーター:

  requestChannel - MessageChannel Bean 名。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(MessageChannel requestChannel)

  提供された requestChannel の「人工的な」GatewayMessageHandler を設定して、デフォルトのオプションでリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。

  パラメーター:

  requestChannel - 使用する MessageChannel。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(MessageChannel requestChannel, @Nullable ConsumerSE<GatewayEndpointSpec> endpointConfigurer)

  提供された requestChannel の「人工」GatewayMessageHandler にデータを入力して、GatewayEndpointSpec のオプションを含むリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。

  パラメーター:

  requestChannel - 使用する MessageChannel。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(IntegrationFlow flow)

  提供された subflow に対応する「人工的な」 GatewayMessageHandler を入力します。通常は aLambda 式と組み合わせて使用します。

   
    .gateway(f -> f.transform("From Gateway SubFlow: "::concat))
   
   

  パラメーター:

  flow - the IntegrationFlow to send a request message and wait for reply.

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(IntegrationFlow flow, @Nullable ConsumerSE<GatewayEndpointSpec> endpointConfigurer)

  提供された subflow の「人工的な」GatewayMessageHandler に GatewayEndpointSpec のオプションを設定します。通常、Lambda 式で使用されます。

   
    .gateway(f -> f.transform("From Gateway SubFlow: "::concat), e -> e.replyTimeout(100L))
   
   

  パラメーター:

  flow - the IntegrationFlow to send a request message and wait for reply.

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• log

  public B log()

  currentMessageChannel の WireTap に、INFO ロギングレベルの LoggingHandler サブスクライバーと、デフォルトのロギングカテゴリとしての org.springframework.integration.handler.LoggingHandler を移入します。

  完全なリクエスト Message がログに記録されます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(LoggingHandler.Level level)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベルの LoggingHandler サブスクライバーと、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler を入力します。

  完全なリクエスト Message がログに記録されます。

  パラメーター:

  level - LoggingHandler.Level

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(StringSE category)

  currentMessageChannel の WireTap に、提供されたロギングカテゴリと INFO ロギングレベルの LoggingHandler サブスクライバを入力します。

  完全なリクエスト Message がログに記録されます。

  パラメーター:

  category - 使用するロギングカテゴリ。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(LoggingHandler.Level level, @Nullable StringSE category)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ロギングレベルおよびロギングカテゴリの LoggingHandler サブスクライバを入力します。

  完全なリクエスト Message がログに記録されます。

  パラメーター:

  level - LoggingHandler.Level

  category - 使用するロギングカテゴリ。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(LoggingHandler.Level level, StringSE category, StringSE logExpression)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベル、ログカテゴリ、ログメッセージの SpEL 式の LoggingHandler サブスクライバを入力します。

  パラメーター:

  level - LoggingHandler.Level

  category - ロギングカテゴリ。

  logExpression - リクエスト Message に対して実行時にロガーメッセージを評価する SpEL 式。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public <P> B log(FunctionSE<Message<P>, ObjectSE> function)

  currentMessageChannel の WireTap に、INFO ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、ログメッセージ用の FunctionSE を入力します。

  型パラメーター:

  P - リクエスト Message に対して、予想されるペイロード型。

  パラメーター:

  function - 実行時にロガーメッセージを評価する関数

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(Expression logExpression)

  currentMessageChannel の WireTap に、INFO ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、リクエスト Message に対して実行時にロガーメッセージを評価するための SpEL 式を入力します。

  パラメーター:

  logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(LoggingHandler.Level level, Expression logExpression)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、リクエスト Message に対して実行時にロガーメッセージを評価するための SpEL 式を入力します。

  パラメーター:

  level - LoggingHandler.Level

  logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(StringSE category, Expression logExpression)

  currentMessageChannel の WireTap に、INFO LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、提供されたログカテゴリ、SpEL 式を入力して、リクエスト Message に対して実行時にロガーメッセージを評価します。

  パラメーター:

  category - ロギングカテゴリ。

  logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public <P> B log(LoggingHandler.Level level, FunctionSE<Message<P>, ObjectSE> function)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、ログメッセージ用の FunctionSE を入力します。

  型パラメーター:

  P - リクエスト Message に対して、予想されるペイロード型。

  パラメーター:

  level - LoggingHandler.Level

  function - 実行時にロガーメッセージを評価する関数

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public <P> B log(StringSE category, FunctionSE<Message<P>, ObjectSE> function)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、提供されたログカテゴリ、ログメッセージの FunctionSE を移入します。

  型パラメーター:

  P - リクエスト Message に対して、予想されるペイロード型。

  パラメーター:

  category - ロギングカテゴリ。

  function - 実行時にロガーメッセージを評価する関数

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public <P> B log(LoggingHandler.Level level, @Nullable StringSE category, FunctionSE<Message<P>, ObjectSE> function)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベル、ログカテゴリ、ログメッセージの FunctionSE の LoggingHandler サブスクライバーを入力します。

  型パラメーター:

  P - リクエスト Message に対して、予想されるペイロード型。

  パラメーター:

  level - LoggingHandler.Level

  category - ロギングカテゴリ。

  function - 実行時にロガーメッセージを評価する関数

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• log

  public B log(LoggingHandler.Level level, @Nullable StringSE category, @Nullable Expression logExpression)

  currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベル、ログカテゴリ、ログメッセージの SpEL 式の LoggingHandler サブスクライバを入力します。

  パラメーター:

  level - LoggingHandler.Level

  category - ロギングカテゴリ。

  logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  • wireTap(WireTapSpec)

• scatterGather

  public B scatterGather(MessageChannel scatterChannel)

  提供された散乱関数用の MessageChannel および収集関数用のデフォルトの AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。

  パラメーター:

  scatterChannel - スキャッティングリクエスト用の MessageChannel

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• scatterGather

  public B scatterGather(MessageChannel scatterChannel, @Nullable ConsumerSE<AggregatorSpec> gatherer)

  提供された散乱関数用の MessageChannel および収集関数用の AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。

  パラメーター:

  scatterChannel - スキャッティングリクエスト用の MessageChannel

  gatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。null にすることができます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• scatterGather

  public B scatterGather(MessageChannel scatterChannel, @Nullable ConsumerSE<AggregatorSpec> gatherer, @Nullable ConsumerSE<ScatterGatherSpec> scatterGather)

  提供された散乱関数用の MessageChannel および収集関数用の AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。

  パラメーター:

  scatterChannel - スキャッティングリクエスト用の MessageChannel

  gatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。null にすることができます。

  scatterGather - ScatterGatherHandler およびそのエンドポイントを構成するための ScatterGatherSpec の ConsumerSE。null にすることができます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• scatterGather

  public B scatterGather(ConsumerSE<RecipientListRouterSpec> scatterer)

  提供された散乱関数用の RecipientListRouterSpec および収集関数用のデフォルトの AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。

  パラメーター:

  scatterer - 散乱体を構成するための RecipientListRouterSpec の ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• scatterGather

  public B scatterGather(ConsumerSE<RecipientListRouterSpec> scatterer, @Nullable ConsumerSE<AggregatorSpec> gatherer)

  提供された散乱関数用の RecipientListRouterSpec および収集関数用の AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。

  パラメーター:

  scatterer - 散乱体を構成するための RecipientListRouterSpec の ConsumerSE。null にすることができます。

  gatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。null にすることができます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• scatterGather

  public B scatterGather(ConsumerSE<RecipientListRouterSpec> scatterer, @Nullable ConsumerSE<AggregatorSpec> gatherer, @Nullable ConsumerSE<ScatterGatherSpec> scatterGather)

  提供された分散機能用の RecipientListRouterSpec と収集機能用の AggregatorSpec に基づいて、現在の統合フロー位置に ScatterGatherHandler を設定します。便宜上、AbstractRouterSpec.applySequence(boolean) はデフォルトで true に設定されています。

  パラメーター:

  scatterer - 散乱体を構成するための RecipientListRouterSpec の ConsumerSE。

  gatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。

  scatterGather - ScatterGatherHandler およびそのエンドポイントを構成するための ScatterGatherSpec の ConsumerSE。null にすることができます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• barrier

  public B barrier(long timeout)

  提供されたタイムアウトの BarrierMessageHandler インスタンスを作成します。

  パラメーター:

  timeout - ミリ秒単位のタイムアウト。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• barrier

  public B barrier(long timeout, @Nullable ConsumerSE<BarrierSpec> barrierConfigurer)

  BarrierSpec から提供されたタイムアウトとオプション、および GenericEndpointSpec からエンドポイントオプションの BarrierMessageHandler インスタンスを作成します。

  パラメーター:

  timeout - ミリ秒単位のタイムアウト。

  barrierConfigurer - BarrierMessageHandler オプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• trigger

  public B trigger(StringSE triggerActionId)

  MessageTriggerAction を実行するには、ServiceActivatingHandler インスタンスにデータを入力します。

  パラメーター:

  triggerActionId - MessageTriggerAction Bean ID。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• trigger

  public B trigger(StringSE triggerActionId, @Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

  GenericEndpointSpec から MessageTriggerAction およびエンドポイントオプションを実行するために、ServiceActivatingHandler インスタンスを入力します。

  パラメーター:

  triggerActionId - MessageTriggerAction Bean ID。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• trigger

  public B trigger(MessageTriggerAction triggerAction)

  MessageTriggerAction を実行するには、ServiceActivatingHandler インスタンスにデータを入力します。

  パラメーター:

  triggerAction - MessageTriggerAction

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• trigger

  public B trigger(MessageTriggerAction triggerAction, @Nullable ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

  GenericEndpointSpec から MessageTriggerAction およびエンドポイントオプションを実行するために、ServiceActivatingHandler インスタンスを入力します。

  パラメーター:

  triggerAction - MessageTriggerAction

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• intercept

  public B intercept(ChannelInterceptor... interceptorArray)

  インターセプターがすでに登録されている後、1 つ以上の ChannelInterceptor 実装を現在の currentMessageChannel に指定された順序で追加します。

  パラメーター:

  interceptorArray - 1 つ以上の ChannelInterceptor。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  例外:

  IllegalArgumentExceptionSE - 1 つ以上の null 引数が提供されている場合

  導入:

  5.3

• fluxTransform

  public <I,O> B fluxTransform(FunctionSE<? super reactor.core.publisher.Flux<Message<I>>, ? extends org.reactivestreams.Publisher<O>> fluxFunction)

  FluxMessageChannel にデータを入力して上流データのリアクティブ処理を開始し、それを Flux にラップし、提供された FunctionSE を Flux.transform(Function) を介して適用し、結果を下流のフローでサブスクライブされている 1 つ以上の FluxMessageChannel に送信します。

  型パラメーター:

  I - 入力ペイロードの型。

  O - 出力型。

  パラメーター:

  fluxFunction - FunctionSE を使用してデータをリアクティブに処理します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• nullChannel

  public IntegrationFlow nullChannel()

  "nullChannel" Bean を、ターミナルオペレーターとしてこのフロー定義に追加します。

  戻り値:

  この定義に基づく IntegrationFlow インスタンス。

  導入:

  5.1

• handleReactive

  public <H extends ReactiveMessageHandler> IntegrationFlow handleReactive(ReactiveMessageHandlerSpec<?,H> messageHandlerSpec)

  選択したプロトコル固有の MessageHandler 実装のターミナルコンシューマーエンドポイントを、それぞれの名前空間ファクトリ (例: Http, Kafka, Files) から設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  型パラメーター:

  H - MessageHandler 型。

  パラメーター:

  messageHandlerSpec - MessageHandlerSpec を使用してプロトコル固有の MessageHandler を設定します。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  6.1

• handleReactive

  public <H extends ReactiveMessageHandler> IntegrationFlow handleReactive(ReactiveMessageHandlerSpec<?,H> messageHandlerSpec, @Nullable ConsumerSE<GenericEndpointSpec<ReactiveMessageHandlerAdapter>> endpointConfigurer)

  選択したプロトコル固有の MessageHandler 実装のターミナルコンシューマーエンドポイントを、それぞれの名前空間ファクトリ (例: Http, Kafka, Files) から設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  型パラメーター:

  H - MessageHandler 型。

  パラメーター:

  messageHandlerSpec - MessageHandlerSpec を使用してプロトコル固有の MessageHandler を設定します。

  endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  6.1

• handleReactive

  public IntegrationFlow handleReactive(ReactiveMessageHandler reactiveMessageHandler)

  ReactiveMessageHandler をターミナル IntegrationFlow オペレーターとして追加します。

  パラメーター:

  reactiveMessageHandler - ReactiveMessageHandler を押してフローを終了します。

  戻り値:

  この定義に基づく IntegrationFlow インスタンス。

  導入:

  6.1

• handleReactive

  public IntegrationFlow handleReactive(ReactiveMessageHandler reactiveMessageHandler, @Nullable ConsumerSE<GenericEndpointSpec<ReactiveMessageHandlerAdapter>> endpointConfigurer)

  ReactiveMessageHandler をターミナル IntegrationFlow オペレーターとして追加します。

  パラメーター:

  reactiveMessageHandler - ReactiveMessageHandler を押してフローを終了します。

  endpointConfigurer - ConsumerSE を使用して、ハンドラーのターゲットエンドポイントを構成します。

  戻り値:

  この定義に基づく IntegrationFlow インスタンス。

  導入:

  6.1

• to

  public IntegrationFlow to(IntegrationFlow other)

  他の IntegrationFlow インスタンスへの委譲でこのフローを終了します。

  パラメーター:

  other - 構成する IntegrationFlow。

  戻り値:

  この定義に基づく IntegrationFlow インスタンス。

  導入:

  5.5.4

• toReactivePublisher

  protected <T> org.reactivestreams.Publisher<Message<T>> toReactivePublisher()

  統合フローを Reactive Streams Publisher Bean として表します。

  型パラメーター:

  T - 予想される payload 型

  戻り値:

  Reactive Streams Publisher

• toReactivePublisher

  protected <T> org.reactivestreams.Publisher<Message<T>> toReactivePublisher(boolean autoStartOnSubscribe)

  統合フローを Reactive Streams Publisher Bean として表します。

  型パラメーター:

  T - 予想される payload 型

  パラメーター:

  autoStartOnSubscribe - パブリッシャーへのサブスクリプションが開始されたときに、フローでメッセージの生成と消費を開始します。これが true に設定されている場合、フローはアプリケーションコンテキストによって自動的に開始されないようにマークされます。

  戻り値:

  Reactive Streams Publisher

  導入:

  5.5.6

• register

  protected <S extends ConsumerEndpointSpec<? super S, ? extends MessageHandler>> B register(S endpointSpec, @Nullable ConsumerSE<? super S> endpointConfigurer)

• registerOutputChannelIfCan

  protected B registerOutputChannelIfCan(MessageChannel outputChannel)

• isOutputChannelRequired

  protected boolean isOutputChannelRequired()

• _this

  protected final B _this()

• get

  protected StandardIntegrationFlow get()

• checkReuse

  protected void checkReuse(MessageProducer replyHandler)

• extractProxyTarget

  protected static @Nullable ObjectSE extractProxyTarget(@Nullable ObjectSE target)