Field Detail

• PARSER

  protected static final SpelExpressionParser PARSER

• integrationComponents

  protected final MapSE<ObjectSE,StringSE> integrationComponents

コンストラクターの詳細

• BaseIntegrationFlowDefinition

  protected BaseIntegrationFlowDefinition()

メソッドの詳細

• addComponent

  protected B addComponent(ObjectSE component)

• addComponent

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

• addComponents

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

• getIntegrationComponents

  protected MapSE<ObjectSE,StringSE> getIntegrationComponents()

• currentComponent

  protected B currentComponent(@Nullable
                               ObjectSE component)

• getCurrentComponent

  @Nullable
  protected ObjectSE getCurrentComponent()

• currentMessageChannel

  protected B currentMessageChannel(@Nullable
                                    MessageChannel currentMessageChannel)

• getCurrentMessageChannel

  @Nullable
  protected 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(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(java.util.function.FunctionSE<Channels,MessageChannelSpec<?,?>> channels)

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

  パラメーター:

  channels - 使用する FunctionSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• publishSubscribeChannel

  public B publishSubscribeChannel(java.util.function.ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• publishSubscribeChannel

  public B publishSubscribeChannel(ExecutorSE executor,
                                   java.util.function.ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)

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

  パラメーター:

  executor - 使用する ExecutorSE。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• publishSubscribeChannel

  public B publishSubscribeChannel(BroadcastCapableChannel broadcastCapableChannel,
                                   java.util.function.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,
                   java.util.function.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,
                   java.util.function.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,
                   java.util.function.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。

  関連事項:

  ExpressionCommandMessageProcessor

• controlBus

  public B controlBus(java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  ExpressionCommandMessageProcessor, GenericEndpointSpec

• transform

  public B transform(StringSE expression)

  SpEL Expression の Transformer EI パターン固有の MessageHandler 実装を実装します。

  パラメーター:

  expression - Transformer Expression

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  ExpressionEvaluatingTransformer

• transform

  public B transform(StringSE expression,
                     java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  SpEL Expression の Transformer EI パターン固有の MessageHandler 実装を実装します。

  パラメーター:

  expression - Transformer Expression

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  ExpressionEvaluatingTransformer

• transform

  public B transform(ObjectSE service)

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

  パラメーター:

  service - 使用するサービス。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  ExpressionEvaluatingTransformer

• transform

  public B transform(ObjectSE service,
                     StringSE methodName)

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

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingTransformer

• transform

  public B transform(ObjectSE service,
                     StringSE methodName,
                     java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

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

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  ExpressionEvaluatingTransformer

• transform

  public B transform(MessageProcessorSpec<?> messageProcessorSpec)

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

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

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingTransformer

• transform

  public B transform(MessageProcessorSpec<?> messageProcessorSpec,
                     java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

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

   .transform(Scripts.script("classpath:myScript.py").variable("foo", bar()),
             e -> e.autoStartup(false))
   
   

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

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

  戻り値:

  現在の 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> payloadType,
                           GenericTransformer<P,T> genericTransformer)

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

  型パラメーター:

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

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

  パラメーター:

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

  genericTransformer - 投入する GenericTransformer

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingTransformer, LambdaMessageProcessor

• convert

  public <P> B convert(ClassSE<P> payloadType,
                       java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

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

  型パラメーター:

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

  パラメーター:

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

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  導入:

  5.1

  関連事項:

  MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpec

• transform

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

  特定の payloadType が実行時に変換するために、提供された GenericTransformer の MessageTransformingHandler インスタンスを生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  型パラメーター:

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

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

  パラメーター:

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

  genericTransformer - 投入する GenericTransformer

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpec

• filter

  public B filter(StringSE expression)

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

  パラメーター:

  expression - SpEL 式。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• filter

  public B filter(StringSE expression,
                  java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer)

  指定された SpEL 式の MessageFilter に MessageSelector を入力します。さらに、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,
                  StringSE methodName)

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

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingSelector

• filter

  public B filter(ObjectSE service,
                  StringSE methodName,
                  java.util.function.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,
                  java.util.function.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> payloadType,
                      GenericSelector<P> genericSelector)

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

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

  型パラメーター:

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

  パラメーター:

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

  genericSelector - 使用する GenericSelector。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor

• filter

  public <P> B filter(ClassSE<P> payloadType,
                      GenericSelector<P> genericSelector,
                      java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer)

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

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

  型パラメーター:

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

  パラメーター:

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

  genericSelector - 使用する GenericSelector。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor, FilterEndpointSpec

• handle

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

  Namespace Factory から、選択したプロトコル固有の MessageHandler 実装の ServiceActivatingHandler を生成します。

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

  型パラメーター:

  H - ターゲット MessageHandler 型。

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(MessageHandler messageHandler)

  提供された MessageHandler 実装の ServiceActivatingHandler を生成します。Java 8 ラムダ式として使用できます。

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

  パラメーター:

  messageHandler - 使用する MessageHandler。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(StringSE beanName,
                  StringSE methodName)

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

  パラメーター:

  beanName - 使用する Bean 名。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(StringSE beanName,
                  StringSE methodName,
                  java.util.function.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,
                  StringSE methodName)

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

  パラメーター:

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

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(ObjectSE service,
                  StringSE methodName,
                  java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

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

  パラメーター:

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

  methodName - 呼び出すメソッド。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

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

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

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

  型パラメーター:

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

  パラメーター:

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

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor

• handle

  public <P> B handle(ClassSE<P> payloadType,
                      GenericHandler<P> handler,
                      java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)

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

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

  型パラメーター:

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

  パラメーター:

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

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

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor

• handle

  public B handle(MessageProcessorSpec<?> messageProcessorSpec)

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

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

  パラメーター:

  messageProcessorSpec - 使用する MessageProcessorSpec。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• handle

  public B handle(MessageProcessorSpec<?> messageProcessorSpec,
                  java.util.function.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,
                                             java.util.function.ConsumerSE<GenericEndpointSpec<H>> endpointConfigurer)

  Namespace Factory から、選択したプロトコル固有の MessageHandler 実装の ServiceActivatingHandler を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。

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

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

   .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(java.util.function.ConsumerSE<GenericEndpointSpec<BridgeHandler>> endpointConfigurer)

  BridgeHandler に現在の統合フロー位置を入力します。通常、Java 8 ラムダ式で使用されます。

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  GenericEndpointSpec

• delay

  public B delay(StringSE groupId)

  デフォルトのオプションを使用して、DelayHandler を現在の統合フロー位置に取り込みます。

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• delay

  public B delay(StringSE groupId,
                 java.util.function.ConsumerSE<DelayerEndpointSpec> endpointConfigurer)

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

  パラメーター:

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

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  DelayerEndpointSpec

• enrich

  public B enrich(java.util.function.ConsumerSE<EnricherSpec> enricherConfigurer)

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

   .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 を生成します。Namespace Factory と一緒に使用できます。

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

  提供された MapBuilder からのヘッダー値を使用して、HeaderEnricher の MessageTransformingHandler を生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。Namespace Factory と一緒に使用できます。

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

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

  パラメーター:

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

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  GenericEndpointSpec

• enrichHeaders

  public B enrichHeaders(java.util.function.ConsumerSE<HeaderEnricherSpec> headerEnricherConfigurer)

  提供された ConsumerSE の結果として、HeaderEnricher の MessageTransformingHandler を生成します。通常、Java 8 ラムダ式で使用されます。

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

  パラメーター:

  headerEnricherConfigurer - 使用する ConsumerSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  HeaderEnricherSpec

• split

  public B split()

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• split

  public B split(java.util.function.ConsumerSE<SplitterEndpointSpec<DefaultMessageSplitter>> endpointConfigurer)

  DefaultMessageSplitter に、現在の統合フロー位置に提供されたオプションを入力します。通常、Java 8 ラムダ式で使用されます。

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public B split(StringSE expression)

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public B split(StringSE expression,
                 java.util.function.ConsumerSE<SplitterEndpointSpec<ExpressionEvaluatingSplitter>> endpointConfigurer)

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

  パラメーター:

  expression - スプリッター SpEL 式。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public B split(ObjectSE service)

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

  パラメーター:

  service - 使用するサービス。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingSplitter

• split

  public B split(ObjectSE service,
                 StringSE methodName)

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

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingSplitter

• split

  public B split(ObjectSE service,
                 StringSE methodName,
                 java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)

  実行時に bean の提供された method を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec, MethodInvokingSplitter

• split

  public B split(StringSE beanName,
                 StringSE methodName)

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

  パラメーター:

  beanName - 使用する Bean 名。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• split

  public B split(StringSE beanName,
                 StringSE methodName,
                 java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)

  実行時に bean の提供された method を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

  パラメーター:

  beanName - 使用する Bean 名。

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

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public B split(MessageProcessorSpec<?> messageProcessorSpec)

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

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

  パラメーター:

  messageProcessorSpec - スプリッター MessageProcessorSpec

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public B split(MessageProcessorSpec<?> messageProcessorSpec,
                 java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)

  提供された MessageProcessorSpec から実行時に MessageProcessor を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。

   .split(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000),
    			, e -> e.applySequence(false))
   
   

  パラメーター:

  messageProcessorSpec - スプリッター MessageProcessorSpec

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public <P> B split(ClassSE<P> payloadType,
                     java.util.function.FunctionSE<P,?> splitter)

  実行時に提供された FunctionSE を評価するために、MethodInvokingSplitter を入力します。通常、Java 8 ラムダ式で使用されます。

   .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

  パラメーター:

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

  splitter - スプリッター FunctionSE

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor

• split

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

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

   .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))))
         , e -> e.applySequence(false))
   
   

  型パラメーター:

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

  パラメーター:

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

  splitter - スプリッター FunctionSE

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor, SplitterEndpointSpec

• split

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

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

  型パラメーター:

  S - AbstractMessageSplitter

  パラメーター:

  splitterMessageHandlerSpec - 投入する MessageHandlerSpec

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public <S extends AbstractMessageSplitter> B split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec,
                                                     java.util.function.ConsumerSE<SplitterEndpointSpec<S>> endpointConfigurer)

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

  型パラメーター:

  S - AbstractMessageSplitter

  パラメーター:

  splitterMessageHandlerSpec - 投入する MessageHandlerSpec

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public B split(AbstractMessageSplitter splitter)

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

  パラメーター:

  splitter - 投入する AbstractMessageSplitter

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• split

  public <S extends AbstractMessageSplitter> B split(S splitter,
                                                     java.util.function.ConsumerSE<SplitterEndpointSpec<S>> endpointConfigurer)

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

  型パラメーター:

  S - AbstractMessageSplitter

  パラメーター:

  splitter - 投入する AbstractMessageSplitter

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  SplitterEndpointSpec

• headerFilter

  public B headerFilter(StringSE... headersToRemove)

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

  パラメーター:

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

  戻り値:

  この BaseIntegrationFlowDefinition。

• headerFilter

  public B headerFilter(StringSE headersToRemove,
                        boolean patternMatch)

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

  パラメーター:

  headersToRemove - MessageHeaders から削除するコンマ区切りのヘッダー（またはパターン）。

  patternMatch - boolean フラグ。headersToRemove をパターンまたは直接ヘッダー名として解釈する必要があるかどうかを示します。

  戻り値:

  この BaseIntegrationFlowDefinition。

• headerFilter

  public B headerFilter(HeaderFilter headerFilter,
                        java.util.function.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,
                        java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)

  ClaimCheckInTransformer の MessageTransformingHandler に、提供されている MessageStore を入力します。さらに、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,
                         java.util.function.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(java.util.function.ConsumerSE<ResequencerSpec> resequencer)

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

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  ResequencerSpec

• aggregate

  public B aggregate()

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• aggregate

  public B aggregate(java.util.function.ConsumerSE<AggregatorSpec> aggregator)

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

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  AggregatorSpec

• route

  public B route(StringSE beanName,
                 StringSE method)

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

  パラメーター:

  beanName - 使用する Bean。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public B route(StringSE beanName,
                 StringSE method,
                 java.util.function.ConsumerSE<RouterSpec<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,
                 StringSE methodName)

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

  パラメーター:

  service - 使用するサービス。

  methodName - 呼び出すメソッド。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  MethodInvokingRouter

• route

  public B route(ObjectSE service,
                 StringSE methodName,
                 java.util.function.ConsumerSE<RouterSpec<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> B route(StringSE expression,
                     java.util.function.ConsumerSE<RouterSpec<T,ExpressionEvaluatingRouter>> routerConfigurer)

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

  型パラメーター:

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

  パラメーター:

  expression - 使用する式。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• route

  public <S,T> B route(ClassSE<S> payloadType,
                       java.util.function.FunctionSE<S,T> router)

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

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

  型パラメーター:

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

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

  パラメーター:

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

  router - 使用する FunctionSE。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor

• route

  public <P,T> B route(ClassSE<P> payloadType,
                       java.util.function.FunctionSE<P,T> router,
                       java.util.function.ConsumerSE<RouterSpec<T,MethodInvokingRouter>> routerConfigurer)

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

   .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 - ターゲットの結果型。

  パラメーター:

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

  router - 使用する FunctionSE。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  LambdaMessageProcessor

• 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,
                 java.util.function.ConsumerSE<RouterSpec<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,
                                                                                                java.util.function.ConsumerSE<S> routerConfigurer)

• routeToRecipients

  public B routeToRecipients(java.util.function.ConsumerSE<RecipientListRouterSpec> routerConfigurer)

  RecipientListRouterSpec のオプションを RecipientListRouter に入力します。通常、Java 8 ラムダ式で使用されます。

   .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(java.util.function.ConsumerSE<RouterSpec<ClassSE<? extends ThrowableSE>,ErrorMessageExceptionTypeRouter>> routerConfigurer)

  RouterSpec のオプションを ErrorMessageExceptionTypeRouter に入力します。通常、Java 8 ラムダ式で使用されます。

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

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

  パラメーター:

  requestChannel - 使用する MessageChannel。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(IntegrationFlow flow)

  提供された subflow の「人工的な」GatewayMessageHandler に入力します。通常、Java 8 ラムダ式で使用されます。

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

  パラメーター:

  flow - IntegrationFlow がリクエストメッセージを送信し、応答を待ちます。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• gateway

  public B gateway(IntegrationFlow flow,
                   java.util.function.ConsumerSE<GatewayEndpointSpec> endpointConfigurer)

  提供された subflow の「人工」GatewayMessageHandler に、GatewayEndpointSpec のオプションを入力します。通常、Java 8 ラムダ式で使用されます。

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

  パラメーター:

  flow - IntegrationFlow がリクエストメッセージを送信し、応答を待ちます。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

• log

  public B log()

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

  public B log(LoggingHandler.Level level)

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

  level - LoggingHandler.Level

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

  public B log(StringSE category)

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

  currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベルとロギングカテゴリの LoggingHandler サブスクライバーを設定します。

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

  level - LoggingHandler.Level

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

  level - LoggingHandler.Level

  category - ロギングカテゴリ。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  型パラメーター:

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

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

  public B log(Expression logExpression)

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

  level - LoggingHandler.Level

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

  public B log(StringSE category,
               Expression logExpression)

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

  category - ロギングカテゴリ。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  型パラメーター:

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

  パラメーター:

  level - LoggingHandler.Level

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  型パラメーター:

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

  パラメーター:

  category - ロギングカテゴリ。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  型パラメーター:

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

  パラメーター:

  level - LoggingHandler.Level

  category - ロギングカテゴリ。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• log

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

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

  この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。

  パラメーター:

  level - LoggingHandler.Level

  category - ロギングカテゴリ。

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

  戻り値:

  現在の BaseIntegrationFlowDefinition。

  関連事項:

  wireTap(WireTapSpec)

• logAndReply

  public IntegrationFlow logAndReply()

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

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

  このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。

  この演算子は、フローの最後でのみ使用できます。

  戻り値:

  このビルダーに基づく IntegrationFlow インスタンス

  関連事項:

  log(), bridge()

• logAndReply

  public IntegrationFlow logAndReply(LoggingHandler.Level level)

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

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

  このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。

  この演算子は、フローの最後でのみ使用できます。

  パラメーター:

  level - LoggingHandler.Level

  戻り値:

  このビルダーに基づく IntegrationFlow インスタンス

  関連事項:

  log(), bridge()

• logAndReply

  public IntegrationFlow logAndReply(StringSE category)

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

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

  このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。

  この演算子は、フローの最後でのみ使用できます。

  パラメーター:

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

  戻り値:

  このビルダーに基づく IntegrationFlow インスタンス

  関連事項:

  log(), bridge()

• logAndReply

  public IntegrationFlow logAndReply(LoggingHandler.Level level,
                                     StringSE category)

  currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベルとロギングカテゴリの LoggingHandler サブスクライバーを設定します。

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

  このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。

  この演算子は、フローの最後でのみ使用できます。

  パラメーター:

  level - LoggingHandler.Level

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

  戻り値:

  このビルダーに基づく IntegrationFlow インスタンス

  関連事項:

  log(), bridge()