クラス IntegrationFlowDefinition<B extends IntegrationFlowDefinition<B>>

メソッドの詳細

• transform

  public <S,T> B transform(GenericTransformer<S,T> genericTransformer)

  提供された GenericTransformer の MessageTransformingHandler インスタンスを設定します。メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.transform(Class, GenericTransformer) を使用します。ショートカット:

   
    .transformWith((transformerSpec) -> transformerSpec.function(genericTransformer))
   
   

  型パラメーター:

  S - ソース型 - 「変換元」。

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

  パラメーター:

  genericTransformer - 投入する GenericTransformer

  戻り値:

  現在の IntegrationFlowDefinition。

  関連事項:

  • MethodInvokingTransformer
  • LambdaMessageProcessor

• filter

  public <P> B filter(GenericSelector<P> genericSelector)

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

   
    .filter("World"::equals)
   
   

  メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.filter(Class, GenericSelector) を使用してください。

  型パラメーター:

  P - ソースのペイロード型。

  パラメーター:

  genericSelector - 使用する GenericSelector。

  戻り値:

  現在の IntegrationFlowDefinition。

• filter

  public <P> B filter(GenericSelector<P> genericSelector, ConsumerSE<FilterEndpointSpec> endpointConfigurer)

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

   
    .filter("World"::equals, e -> e.autoStartup(false))
   
   

  メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.filter(Class, GenericSelector, Consumer) を使用してください。

  型パラメーター:

  P - ソースのペイロード型。

  パラメーター:

  genericSelector - 使用する GenericSelector。

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

  戻り値:

  現在の IntegrationFlowDefinition。

  関連事項:

  • FilterEndpointSpec

• handle

  public <P> B handle(GenericHandler<P> handler)

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

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

  メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.handle(Class, GenericHandler) を使用してください。

  型パラメーター:

  P - 期待するペイロード型。

  パラメーター:

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

  戻り値:

  現在の IntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor

• handle

  public <P> B handle(GenericHandler<P> handler, ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

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

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

  メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.handle(Class, GenericHandler, Consumer) を使用してください。

  型パラメーター:

  P - 期待するペイロード型。

  パラメーター:

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

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

  戻り値:

  現在の IntegrationFlowDefinition。

  関連事項:

  • LambdaMessageProcessor
  • GenericEndpointSpec

• route

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

  提供された FunctionSE の MethodInvokingRouter にデフォルトのオプションを入力します。通常、Java 8 ラムダ式で使用されます。

   
    .route(p -> p.equals("foo") || p.equals("bar") ? new String[] {"foo", "bar"} : null)
   
   

  メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.route(Class, Function) を使用してください。

  型パラメーター:

  S - ソースのペイロード型。

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

  パラメーター:

  router - 使用する FunctionSE。

  戻り値:

  現在の IntegrationFlowDefinition。

• route

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

  提供された FunctionSE の MethodInvokingRouter に、RouterSpec から提供されたオプションを設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。

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

  メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.route(Class, Function, Consumer) を使用してください。

  型パラメーター:

  S - ソースのペイロード型。

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

  パラメーター:

  router - 使用する FunctionSE。

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

  戻り値:

  現在の IntegrationFlowDefinition。