メソッドの詳細

• transform

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

  提供された GenericTransformer の MessageTransformingHandler インスタンスを生成します。メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.transform(Class, GenericTransformer) を使用してください。

  型パラメーター:

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

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

  パラメーター:

  genericTransformer - 投入する GenericTransformer

  戻り値:

  現在の IntegrationFlowDefinition。

  関連事項:

  MethodInvokingTransformer, LambdaMessageProcessor

• transform

  public <S,T> B transform(GenericTransformer<S,T> genericTransformer,
                           java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  提供された GenericTransformer の MessageTransformingHandler インスタンスを生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。メッセージ全体にアクセスする必要がある場合は、BaseIntegrationFlowDefinition.transform(Class, GenericTransformer, Consumer) を使用してください。

  型パラメーター:

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

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

  パラメーター:

  genericTransformer - 投入する GenericTransformer

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

  戻り値:

  現在の IntegrationFlowDefinition。

  関連事項:

  MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpec

• 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,
                      java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer)

  提供された GenericSelector の MethodInvokingSelector を MessageFilter に入力します。さらに、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,
                      java.util.function.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

• split

  public <P> B split(java.util.function.FunctionSE<P,?> splitter,
                     java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)

  実行時に提供された FunctionSE を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。

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

  型パラメーター:

  P - ペイロード型。

  パラメーター:

  splitter - スプリッター FunctionSE

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

  戻り値:

  現在の IntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor, SplitterEndpointSpec

• route

  public <S,T> B route(java.util.function.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> B route(java.util.function.FunctionSE<S,T> router,
                       java.util.function.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。