IntegrationFlowDefinition (Spring Integration 5.3.5.RELEASE API)

java.lang.Object
- org.springframework.integration.dsl.BaseIntegrationFlowDefinition
- - org.springframework.integration.dsl.IntegrationFlowDefinition

Type Parameters:

B - the IntegrationFlowDefinition implementation type.

Direct Known Subclasses:

IntegrationFlowBuilder, IntegrationFlowExtension
```
public abstract class IntegrationFlowDefinition>
extends BaseIntegrationFlowDefinition
```
The BaseIntegrationFlowDefinition extension for syntax sugar with generics for some type-based EIP-methods when an expected payload type is assumed from upstream. For more explicit type conversion the methods with a Class argument are recommended for use.

Since:

5.0

Author:

Artem Bilan, Gary Russell, Gabriele Del Prete

Nested Class Summary
- Nested classes/interfaces inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
  BaseIntegrationFlowDefinition.ReplyProducerCleaner

Field Summary
- Fields inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
  integrationComponents, PARSER

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`B`	`aggregate()` Populate the `AggregatingMessageHandler` with default options.
`B`	`aggregate(java.util.function.Consumer<AggregatorSpec> aggregator)` Populate the `AggregatingMessageHandler` with provided options from `AggregatorSpec`.
`B`	`barrier(long timeout)` Populate a `BarrierMessageHandler` instance for provided timeout.
`B`	`barrier(long timeout, java.util.function.Consumer<BarrierSpec> barrierConfigurer)` Populate a `BarrierMessageHandler` instance for provided timeout and options from `BarrierSpec` and endpoint options from `GenericEndpointSpec`.
`B`	`bridge()` Populate a `BridgeHandler` to the current integration flow position.
`B`	`bridge(java.util.function.Consumer<GenericEndpointSpec<BridgeHandler>> endpointConfigurer)` Populate a `BridgeHandler` to the current integration flow position.
`B`	`channel(java.util.function.Function<Channels,MessageChannelSpec<?,?>> channels)` Populate a `MessageChannel` instance at the current `IntegrationFlow` chain position using the `Channels` factory fluent API.
`B`	`channel(MessageChannel messageChannel)` Populate the provided `MessageChannel` instance at the current `IntegrationFlow` chain position.
`B`	`channel(MessageChannelSpec<?,?> messageChannelSpec)` Populate a `MessageChannel` instance at the current `IntegrationFlow` chain position using the `MessageChannelSpec` fluent API.
`B`	`channel(String messageChannelName)` Populate a `MessageChannelReference` instance at the current `IntegrationFlow` chain position.
`B`	`claimCheckIn(MessageStore messageStore)` Populate the `MessageTransformingHandler` for the `ClaimCheckInTransformer` with provided `MessageStore`.
`B`	`claimCheckIn(MessageStore messageStore, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `MessageTransformingHandler` for the `ClaimCheckInTransformer` with provided `MessageStore`.
`B`	`claimCheckOut(MessageStore messageStore)` Populate the `MessageTransformingHandler` for the `ClaimCheckOutTransformer` with provided `MessageStore`.
`B`	`claimCheckOut(MessageStore messageStore, boolean removeMessage)` Populate the `MessageTransformingHandler` for the `ClaimCheckOutTransformer` with provided `MessageStore` and `removeMessage` flag.
`B`	`claimCheckOut(MessageStore messageStore, boolean removeMessage, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `MessageTransformingHandler` for the `ClaimCheckOutTransformer` with provided `MessageStore` and `removeMessage` flag.
`B`	`controlBus()` Populate the `Control Bus` EI Pattern specific `MessageHandler` implementation at the current `IntegrationFlow` chain position.
`B`	`controlBus(java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate the `Control Bus` EI Pattern specific `MessageHandler` implementation at the current `IntegrationFlow` chain position.
`<P> B`	`convert(Class<P> payloadType)` Populate the `MessageTransformingHandler` instance for the provided `payloadType` to convert at runtime.
`<P> B`	`convert(Class<P> payloadType, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `MessageTransformingHandler` instance for the provided `payloadType` to convert at runtime.
`B`	`delay(String groupId)` Populate a `DelayHandler` to the current integration flow position with default options.
`B`	`delay(String groupId, java.util.function.Consumer<DelayerEndpointSpec> endpointConfigurer)` Populate a `DelayHandler` to the current integration flow position.
`B`	`enrich(java.util.function.Consumer<EnricherSpec> enricherConfigurer)` Populate a `ContentEnricher` to the current integration flow position with provided options.
`B`	`enrichHeaders(java.util.function.Consumer<HeaderEnricherSpec> headerEnricherConfigurer)` Populate a `MessageTransformingHandler` for a `HeaderEnricher` as the result of provided `Consumer`.
`B`	`enrichHeaders(Map<String,Object> headers)` Accept a `Map` of values to be used for the `Message` header enrichment.
`B`	`enrichHeaders(Map<String,Object> headers, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Accept a `Map` of values to be used for the `Message` header enrichment.
`B`	`enrichHeaders(MapBuilder<?,String,Object> headers)` Populate a `MessageTransformingHandler` for a `HeaderEnricher` using header values from provided `MapBuilder`.
`B`	`enrichHeaders(MapBuilder<?,String,Object> headers, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate a `MessageTransformingHandler` for a `HeaderEnricher` using header values from provided `MapBuilder`.
`<P> B`	`filter(Class<P> payloadType, GenericSelector<P> genericSelector)` Populate a `MessageFilter` with `MethodInvokingSelector` for the provided `GenericSelector`.
`<P> B`	`filter(Class<P> payloadType, GenericSelector<P> genericSelector, java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)` Populate a `MessageFilter` with `MethodInvokingSelector` for the provided `GenericSelector`.
`<P> B`	`filter(GenericSelector<P> genericSelector)` Populate a `MessageFilter` with `MethodInvokingSelector` for the provided `GenericSelector`.
`<P> B`	`filter(GenericSelector<P> genericSelector, java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)` Populate a `MessageFilter` with `MethodInvokingSelector` for the provided `GenericSelector`.
`B`	`filter(MessageProcessorSpec<?> messageProcessorSpec)` Populate a `MessageFilter` with `MethodInvokingSelector` for the `MessageProcessor` from the provided `MessageProcessorSpec`.
`B`	`filter(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)` Populate a `MessageFilter` with `MethodInvokingSelector` for the `MessageProcessor` from the provided `MessageProcessorSpec`.
`B`	`filter(Object service)` Populate a `MessageFilter` with `MethodInvokingSelector` for the discovered method of the provided service.
`B`	`filter(Object service, String methodName)` Populate a `MessageFilter` with `MethodInvokingSelector` for the method of the provided service.
`B`	`filter(Object service, String methodName, java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)` Populate a `MessageFilter` with `MethodInvokingSelector` for the method of the provided service.
`B`	`filter(String expression)` Populate a `MessageFilter` with `MessageSelector` for the provided SpEL expression.
`B`	`filter(String expression, java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)` Populate a `MessageFilter` with `MessageSelector` for the provided SpEL expression.
`B`	`fixedSubscriberChannel()` Populate an `FixedSubscriberChannel` instance at the current `IntegrationFlow` chain position.
`B`	`fixedSubscriberChannel(String messageChannelName)` Populate an `FixedSubscriberChannel` instance at the current `IntegrationFlow` chain position.
`<I,O> B`	`fluxTransform(java.util.function.Function<? super reactor.core.publisher.Flux<Message<I>>,? extends org.reactivestreams.Publisher<O>> fluxFunction)` Populate a `FluxMessageChannel` to start a reactive processing for upstream data, wrap it to a `Flux`, apply provided `Function` via `Flux.transform(Function)` and emit the result to one more `FluxMessageChannel`, subscribed in the downstream flow.
`B`	`gateway(IntegrationFlow flow)` Populate the "artificial" `GatewayMessageHandler` for the provided `subflow`.
`B`	`gateway(IntegrationFlow flow, java.util.function.Consumer<GatewayEndpointSpec> endpointConfigurer)` Populate the "artificial" `GatewayMessageHandler` for the provided `subflow` with options from `GatewayEndpointSpec`.
`B`	`gateway(MessageChannel requestChannel)` Populate the "artificial" `GatewayMessageHandler` for the provided `requestChannel` to send a request with default options.
`B`	`gateway(MessageChannel requestChannel, java.util.function.Consumer<GatewayEndpointSpec> endpointConfigurer)` Populate the "artificial" `GatewayMessageHandler` for the provided `requestChannel` to send a request with options from `GatewayEndpointSpec`.
`B`	`gateway(String requestChannel)` Populate the "artificial" `GatewayMessageHandler` for the provided `requestChannel` to send a request with default options.
`B`	`gateway(String requestChannel, java.util.function.Consumer<GatewayEndpointSpec> endpointConfigurer)` Populate the "artificial" `GatewayMessageHandler` for the provided `requestChannel` to send a request with options from `GatewayEndpointSpec`.
`<P> B`	`handle(Class<P> payloadType, GenericHandler<P> handler)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the provided `GenericHandler` at runtime.
`<P> B`	`handle(Class<P> payloadType, GenericHandler<P> handler, java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the provided `GenericHandler` at runtime.
`<P> B`	`handle(GenericHandler<P> handler)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the provided `GenericHandler` at runtime.
`<P> B`	`handle(GenericHandler<P> handler, java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the provided `GenericHandler` at runtime.
`<H extends MessageHandler> B`	`handle(H messageHandler, java.util.function.Consumer<GenericEndpointSpec<H>> endpointConfigurer)` Populate a `ServiceActivatingHandler` for the provided `MessageHandler` implementation.
`B`	`handle(MessageHandler messageHandler)` Populate a `ServiceActivatingHandler` for the provided `MessageHandler` implementation.
`<H extends MessageHandler> B`	`handle(MessageHandlerSpec<?,H> messageHandlerSpec)` Populate a `ServiceActivatingHandler` for the selected protocol specific `MessageHandler` implementation from `Namespace Factory`: `.handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"))`
`<H extends MessageHandler> B`	`handle(MessageHandlerSpec<?,H> messageHandlerSpec, java.util.function.Consumer<GenericEndpointSpec<H>> endpointConfigurer)` Populate a `ServiceActivatingHandler` for the selected protocol specific `MessageHandler` implementation from `Namespace Factory`: In addition accept options for the integration endpoint using `GenericEndpointSpec`.
`B`	`handle(MessageProcessorSpec<?> messageProcessorSpec)` Populate a `ServiceActivatingHandler` for the `MessageProcessor` from the provided `MessageProcessorSpec`.
`B`	`handle(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate a `ServiceActivatingHandler` for the `MessageProcessor` from the provided `MessageProcessorSpec`.
`B`	`handle(Object service)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the discovered `method` for provided `service` at runtime.
`B`	`handle(Object service, String methodName)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the `method` for provided `bean` at runtime.
`B`	`handle(Object service, String methodName, java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the `method` for provided `bean` at runtime.
`B`	`handle(String beanName, String methodName)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the `method` for provided `bean` at runtime.
`B`	`handle(String beanName, String methodName, java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate a `ServiceActivatingHandler` for the `MethodInvokingMessageProcessor` to invoke the `method` for provided `bean` at runtime.
`B`	`headerFilter(HeaderFilter headerFilter, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the provided `MessageTransformingHandler` for the provided `HeaderFilter`.
`B`	`headerFilter(String... headersToRemove)` Provide the `HeaderFilter` to the current `StandardIntegrationFlow`.
`B`	`headerFilter(String headersToRemove, boolean patternMatch)` Provide the `HeaderFilter` to the current `StandardIntegrationFlow`.
`B`	`log()` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` logging level and `org.springframework.integration.handler.LoggingHandler` as a default logging category.
`B`	`log(Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and SpEL expression to evaluate logger message at runtime against the request `Message`.
`<P> B`	`log(java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and `Function` for the log message.
`B`	`log(LoggingHandler.Level level)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for provided `LoggingHandler.Level` logging level and `org.springframework.integration.handler.LoggingHandler` as a default logging category.
`B`	`log(LoggingHandler.Level level, Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and SpEL expression to evaluate logger message at runtime against the request `Message`.
`<P> B`	`log(LoggingHandler.Level level, java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and `Function` for the log message.
`B`	`log(LoggingHandler.Level level, String category)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level and logging category.
`B`	`log(LoggingHandler.Level level, String category, Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, logging category and SpEL expression for the log message.
`<P> B`	`log(LoggingHandler.Level level, String category, java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, logging category and `Function` for the log message.
`B`	`log(LoggingHandler.Level level, String category, String logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, logging category and SpEL expression for the log message.
`B`	`log(String category)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided logging category and `INFO` logging level.
`B`	`log(String category, Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` `LoggingHandler.Level` logging level, the provided logging category and SpEL expression to evaluate logger message at runtime against the request `Message`.
`<P> B`	`log(String category, java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, the provided logging category and `Function` for the log message.
`IntegrationFlow`	`logAndReply()` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` logging level and `org.springframework.integration.handler.LoggingHandler` as a default logging category.
`IntegrationFlow`	`logAndReply(Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and SpEL expression to evaluate logger message at runtime against the request `Message`.
`<P> IntegrationFlow`	`logAndReply(java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and `Function` for the log message.
`IntegrationFlow`	`logAndReply(LoggingHandler.Level level)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for provided `LoggingHandler.Level` logging level and `org.springframework.integration.handler.LoggingHandler` as a default logging category.
`IntegrationFlow`	`logAndReply(LoggingHandler.Level level, Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and SpEL expression to evaluate logger message at runtime against the request `Message`.
`<P> IntegrationFlow`	`logAndReply(LoggingHandler.Level level, java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, the `org.springframework.integration.handler.LoggingHandler` as a default logging category and `Function` for the log message.
`IntegrationFlow`	`logAndReply(LoggingHandler.Level level, String category)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level and logging category.
`IntegrationFlow`	`logAndReply(LoggingHandler.Level level, String category, Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, logging category and SpEL expression for the log message.
`<P> IntegrationFlow`	`logAndReply(LoggingHandler.Level level, String category, java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, logging category and `Function` for the log message.
`IntegrationFlow`	`logAndReply(LoggingHandler.Level level, String category, String logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, logging category and SpEL expression for the log message.
`IntegrationFlow`	`logAndReply(String category)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided logging category and `INFO` logging level.
`IntegrationFlow`	`logAndReply(String category, Expression logExpression)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the `INFO` `LoggingHandler.Level` logging level, the provided logging category and SpEL expression to evaluate logger message at runtime against the request `Message`.
`<P> IntegrationFlow`	`logAndReply(String category, java.util.function.Function<Message<P>,Object> function)` Populate a `WireTap` for the `BaseIntegrationFlowDefinition.currentMessageChannel` with the `LoggingHandler` subscriber for the provided `LoggingHandler.Level` logging level, the provided logging category and `Function` for the log message.
`IntegrationFlow`	`nullChannel()` Add a bean into this flow definition as a terminal operator.
`B`	`publishSubscribeChannel(java.util.function.Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer)` The `PublishSubscribeChannel` `BaseIntegrationFlowDefinition.channel(java.lang.String)` method specific implementation to allow the use of the 'subflow' subscriber capability.
`B`	`publishSubscribeChannel(Executor executor, java.util.function.Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer)` The `PublishSubscribeChannel` `BaseIntegrationFlowDefinition.channel(java.lang.String)` method specific implementation to allow the use of the 'subflow' subscriber capability.
`B`	`resequence()` Populate the `ResequencingMessageHandler` with default options.
`B`	`resequence(java.util.function.Consumer<ResequencerSpec> resequencer)` Populate the `ResequencingMessageHandler` with provided options from `ResequencerSpec`.
`B`	`route(AbstractMessageRouter router)` Populate the provided `AbstractMessageRouter` implementation to the current integration flow position.
`<P,T> B`	`route(Class<P> payloadType, java.util.function.Function<P,T> router, java.util.function.Consumer<RouterSpec<T,MethodInvokingRouter>> routerConfigurer)` Populate the `MethodInvokingRouter` for provided `Function` and payload type and options from `RouterSpec`.
`<S,T> B`	`route(Class<S> payloadType, java.util.function.Function<S,T> router)` Populate the `MethodInvokingRouter` for provided `Function` and payload type with default options.
`<S,T> B`	`route(java.util.function.Function<S,T> router)` Populate the `MethodInvokingRouter` for provided `Function` with default options.
`<S,T> B`	`route(java.util.function.Function<S,T> router, java.util.function.Consumer<RouterSpec<T,MethodInvokingRouter>> routerConfigurer)` Populate the `MethodInvokingRouter` for provided `Function` with provided options from `RouterSpec`.
`B`	`route(MessageProcessorSpec<?> messageProcessorSpec)` Populate the `MethodInvokingRouter` for the `MessageProcessor` from the provided `MessageProcessorSpec` with default options.
`B`	`route(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.Consumer<RouterSpec<Object,MethodInvokingRouter>> routerConfigurer)` Populate the `MethodInvokingRouter` for the `MessageProcessor` from the provided `MessageProcessorSpec` with default options.
`B`	`route(Object service)` Populate the `MethodInvokingRouter` for the discovered method of the provided service and its method with default options.
`B`	`route(Object service, String methodName)` Populate the `MethodInvokingRouter` for the method of the provided service and its method with default options.
`B`	`route(Object service, String methodName, java.util.function.Consumer<RouterSpec<Object,MethodInvokingRouter>> routerConfigurer)` Populate the `MethodInvokingRouter` for the method of the provided service and its method with provided options from `RouterSpec`.
`<R extends AbstractMessageRouter> B`	`route(R router, java.util.function.Consumer<GenericEndpointSpec<R>> endpointConfigurer)` Populate the provided `AbstractMessageRouter` implementation to the current integration flow position.
`B`	`route(String expression)` Populate the `ExpressionEvaluatingRouter` for provided SpEL expression with default options.
`<T> B`	`route(String expression, java.util.function.Consumer<RouterSpec<T,ExpressionEvaluatingRouter>> routerConfigurer)` Populate the `ExpressionEvaluatingRouter` for provided SpEL expression with provided options from `RouterSpec`.
`B`	`route(String beanName, String method)` Populate the `MethodInvokingRouter` for provided bean and its method with default options.
`B`	`route(String beanName, String method, java.util.function.Consumer<RouterSpec<Object,MethodInvokingRouter>> routerConfigurer)` Populate the `MethodInvokingRouter` for provided bean and its method with provided options from `RouterSpec`.
`B`	`routeByException(java.util.function.Consumer<RouterSpec<Class<? extends Throwable>,ErrorMessageExceptionTypeRouter>> routerConfigurer)` Populate the `ErrorMessageExceptionTypeRouter` with options from the `RouterSpec`.
`B`	`routeToRecipients(java.util.function.Consumer<RecipientListRouterSpec> routerConfigurer)` Populate the `RecipientListRouter` with options from the `RecipientListRouterSpec`.
`B`	`scatterGather(java.util.function.Consumer<RecipientListRouterSpec> scatterer)` Populate a `ScatterGatherHandler` to the current integration flow position based on the provided `RecipientListRouterSpec` for scattering function and default `AggregatorSpec` for gathering function.
`B`	`scatterGather(java.util.function.Consumer<RecipientListRouterSpec> scatterer, java.util.function.Consumer<AggregatorSpec> gatherer)` Populate a `ScatterGatherHandler` to the current integration flow position based on the provided `RecipientListRouterSpec` for scattering function and `AggregatorSpec` for gathering function.
`B`	`scatterGather(java.util.function.Consumer<RecipientListRouterSpec> scatterer, java.util.function.Consumer<AggregatorSpec> gatherer, java.util.function.Consumer<ScatterGatherSpec> scatterGather)` Populate a `ScatterGatherHandler` to the current integration flow position based on the provided `RecipientListRouterSpec` for scattering function and `AggregatorSpec` for gathering function.
`B`	`scatterGather(MessageChannel scatterChannel)` Populate a `ScatterGatherHandler` to the current integration flow position based on the provided `MessageChannel` for scattering function and default `AggregatorSpec` for gathering function.
`B`	`scatterGather(MessageChannel scatterChannel, java.util.function.Consumer<AggregatorSpec> gatherer)` Populate a `ScatterGatherHandler` to the current integration flow position based on the provided `MessageChannel` for scattering function and `AggregatorSpec` for gathering function.
`B`	`scatterGather(MessageChannel scatterChannel, java.util.function.Consumer<AggregatorSpec> gatherer, java.util.function.Consumer<ScatterGatherSpec> scatterGather)` Populate a `ScatterGatherHandler` to the current integration flow position based on the provided `MessageChannel` for scattering function and `AggregatorSpec` for gathering function.
`B`	`split()` Populate the `DefaultMessageSplitter` with default options to the current integration flow position.
`B`	`split(AbstractMessageSplitter splitter)` Populate the provided `AbstractMessageSplitter` to the current integration flow position.
`<P> B`	`split(Class<P> payloadType, java.util.function.Function<P,?> splitter)` Populate the `MethodInvokingSplitter` to evaluate the provided `Function` at runtime.
`<P> B`	`split(Class<P> payloadType, java.util.function.Function<P,?> splitter, java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)` Populate the `MethodInvokingSplitter` to evaluate the provided `Function` at runtime.
`B`	`split(java.util.function.Consumer<SplitterEndpointSpec<DefaultMessageSplitter>> endpointConfigurer)` Populate the `DefaultMessageSplitter` with provided options to the current integration flow position.
`<P> B`	`split(java.util.function.Function<P,?> splitter, java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)` Populate the `MethodInvokingSplitter` to evaluate the provided `Function` at runtime.
`<S extends AbstractMessageSplitter> B`	`split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec)` Populate the provided `AbstractMessageSplitter` to the current integration flow position.
`<S extends AbstractMessageSplitter> B`	`split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec, java.util.function.Consumer<SplitterEndpointSpec<S>> endpointConfigurer)` Populate the provided `AbstractMessageSplitter` to the current integration flow position.
`B`	`split(MessageProcessorSpec<?> messageProcessorSpec)` Populate the `MethodInvokingSplitter` to evaluate the `MessageProcessor` at runtime from provided `MessageProcessorSpec`.
`B`	`split(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)` Populate the `MethodInvokingSplitter` to evaluate the `MessageProcessor` at runtime from provided `MessageProcessorSpec`.
`B`	`split(Object service)` Populate the `MethodInvokingSplitter` to evaluate the discovered `method` of the `service` at runtime.
`B`	`split(Object service, String methodName)` Populate the `MethodInvokingSplitter` to evaluate the provided `method` of the `service` at runtime.
`B`	`split(Object service, String methodName, java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)` Populate the `MethodInvokingSplitter` to evaluate the provided `method` of the `bean` at runtime.
`<S extends AbstractMessageSplitter> B`	`split(S splitter, java.util.function.Consumer<SplitterEndpointSpec<S>> endpointConfigurer)` Populate the provided `AbstractMessageSplitter` to the current integration flow position.
`B`	`split(String expression)` Populate the `ExpressionEvaluatingSplitter` with provided SpEL expression.
`B`	`split(String expression, java.util.function.Consumer<SplitterEndpointSpec<ExpressionEvaluatingSplitter>> endpointConfigurer)` Populate the `ExpressionEvaluatingSplitter` with provided SpEL expression.
`B`	`split(String beanName, String methodName)` Populate the `MethodInvokingSplitter` to evaluate the provided `method` of the `bean` at runtime.
`B`	`split(String beanName, String methodName, java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)` Populate the `MethodInvokingSplitter` to evaluate the provided `method` of the `bean` at runtime.
`<P,T> B`	`transform(Class<P> payloadType, GenericTransformer<P,T> genericTransformer)` Populate the `MessageTransformingHandler` instance for the provided `GenericTransformer` for the specific `payloadType` to convert at runtime.
`<P,T> B`	`transform(Class<P> payloadType, GenericTransformer<P,T> genericTransformer, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `MessageTransformingHandler` instance for the provided `GenericTransformer` for the specific `payloadType` to convert at runtime.
`<S,T> B`	`transform(GenericTransformer<S,T> genericTransformer)` Populate the `MessageTransformingHandler` instance for the provided `GenericTransformer`.
`<S,T> B`	`transform(GenericTransformer<S,T> genericTransformer, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `MessageTransformingHandler` instance for the provided `GenericTransformer`.
`B`	`transform(MessageProcessorSpec<?> messageProcessorSpec)` Populate the `MessageTransformingHandler` instance for the `MessageProcessor` from provided `MessageProcessorSpec`.
`B`	`transform(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `MessageTransformingHandler` instance for the `MessageProcessor` from provided `MessageProcessorSpec`.
`B`	`transform(Object service)` Populate the `MessageTransformingHandler` for the `MethodInvokingTransformer` to invoke the discovered service method at runtime.
`B`	`transform(Object service, String methodName)` Populate the `MessageTransformingHandler` for the `MethodInvokingTransformer` to invoke the service method at runtime.
`B`	`transform(Object service, String methodName, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `MessageTransformingHandler` for the `MethodInvokingTransformer` to invoke the service method at runtime.
`B`	`transform(String expression)` Populate the `Transformer` EI Pattern specific `MessageHandler` implementation for the SpEL `Expression`.
`B`	`transform(String expression, java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)` Populate the `Transformer` EI Pattern specific `MessageHandler` implementation for the SpEL `Expression`.
`B`	`trigger(MessageTriggerAction triggerAction)` Populate a `ServiceActivatingHandler` instance to perform `MessageTriggerAction`.
`B`	`trigger(MessageTriggerAction triggerAction, java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate a `ServiceActivatingHandler` instance to perform `MessageTriggerAction` and endpoint options from `GenericEndpointSpec`.
`B`	`trigger(String triggerActionId)` Populate a `ServiceActivatingHandler` instance to perform `MessageTriggerAction`.
`B`	`trigger(String triggerActionId, java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)` Populate a `ServiceActivatingHandler` instance to perform `MessageTriggerAction` and endpoint options from `GenericEndpointSpec`.
`B`	`wireTap(IntegrationFlow flow)` Populate the `Wire Tap` EI Pattern specific `ChannelInterceptor` implementation to the current `BaseIntegrationFlowDefinition.currentMessageChannel`.
`B`	`wireTap(IntegrationFlow flow, java.util.function.Consumer<WireTapSpec> wireTapConfigurer)` Populate the `Wire Tap` EI Pattern specific `ChannelInterceptor` implementation to the current `BaseIntegrationFlowDefinition.currentMessageChannel`.
`B`	`wireTap(MessageChannel wireTapChannel)` Populate the `Wire Tap` EI Pattern specific `ChannelInterceptor` implementation to the current `BaseIntegrationFlowDefinition.currentMessageChannel`.
`B`	`wireTap(MessageChannel wireTapChannel, java.util.function.Consumer<WireTapSpec> wireTapConfigurer)` Populate the `Wire Tap` EI Pattern specific `ChannelInterceptor` implementation to the current `BaseIntegrationFlowDefinition.currentMessageChannel`.
`B`	`wireTap(String wireTapChannel)` Populate the `Wire Tap` EI Pattern specific `ChannelInterceptor` implementation to the current `BaseIntegrationFlowDefinition.currentMessageChannel`.
`B`	`wireTap(String wireTapChannel, java.util.function.Consumer<WireTapSpec> wireTapConfigurer)` Populate the `Wire Tap` EI Pattern specific `ChannelInterceptor` implementation to the current `BaseIntegrationFlowDefinition.currentMessageChannel`.
`B`	`wireTap(WireTapSpec wireTapSpec)` Populate the `Wire Tap` EI Pattern specific `ChannelInterceptor` implementation to the current `BaseIntegrationFlowDefinition.currentMessageChannel`.

Methods inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
_this, addComponent, addComponent, addComponents, checkReuse, currentComponent, currentInterceptableChannel, currentMessageChannel, extractProxyTarget, get, getCurrentComponent, getCurrentMessageChannel, getIntegrationComponents, intercept, isImplicitChannel, isOutputChannelRequired, obtainInputChannelFromFlow, publishSubscribeChannel, register, registerOutputChannelIfCan, route, setImplicitChannel, toReactivePublisher

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
 - transform
```
public <S,T> B transform(GenericTransformer<S,T> genericTransformer)
```
 Populate the MessageTransformingHandler instance for the provided GenericTransformer. Use transform(Class, GenericTransformer) if you need to access the entire message.
 
 Type Parameters:
 
 S - the source type - 'transform from'.
 
 T - the target type - 'transform to'.
 
 Parameters:
 
 genericTransformer - the GenericTransformer to populate.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer, LambdaMessageProcessor
 - transform
```
public <S,T> B transform(GenericTransformer<S,T> genericTransformer,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Populate the MessageTransformingHandler instance for the provided GenericTransformer. In addition accept options for the integration endpoint using GenericEndpointSpec. Use transform(Class, GenericTransformer, Consumer) if you need to access the entire message.
 
 Type Parameters:
 
 S - the source type - 'transform from'.
 
 T - the target type - 'transform to'.
 
 Parameters:
 
 genericTransformer - the GenericTransformer to populate.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpec
 - filter
```
public  B filter(GenericSelector genericSelector)
```
 Populate a MessageFilter with MethodInvokingSelector for the provided GenericSelector. Typically used with a Java 8 Lambda expression:
```
 .filter("World"::equals)
 
 
```
 Use filter(Class, GenericSelector) if you need to access the entire message.
 Type Parameters:
 
 P - the source payload type.
 
 Parameters:
 
 genericSelector - the GenericSelector to use.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 - filter
```
public  B filter(GenericSelector genericSelector,
 java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)
```
 Populate a MessageFilter with MethodInvokingSelector for the provided GenericSelector. In addition accept options for the integration endpoint using FilterEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .filter("World"::equals, e -> e.autoStartup(false))
 
 
```
 Use filter(Class, GenericSelector, Consumer) if you need to access the entire message.
 Type Parameters:
 
 P - the source payload type.
 
 Parameters:
 
 genericSelector - the GenericSelector to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 
 See Also:
 
 FilterEndpointSpec
 - handle
```
public  B handle(GenericHandler handler)
```
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the provided GenericHandler at runtime. Typically used with a Java 8 Lambda expression:
```
 .<Integer>handle((p, h) -> p / 2)
 
 
```
 Use handle(Class, GenericHandler) if you need to access the entire message.
 Type Parameters:
 
 P - the payload type to expect.
 
 Parameters:
 
 handler - the handler to invoke.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor
 - handle
```
public  B handle(GenericHandler handler,
 java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the provided GenericHandler at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .<Integer>handle((p, h) -> p / 2, e -> e.autoStartup(false))
 
 
```
 Use handle(Class, GenericHandler, Consumer) if you need to access the entire message.
 Type Parameters:
 
 P - the payload type to expect.
 
 Parameters:
 
 handler - the handler to invoke.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor, GenericEndpointSpec
 - split
```
public  B split(java.util.function.Function<P,?> splitter,
 java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
```
 Populate the MethodInvokingSplitter to evaluate the provided Function at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .<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))
 
 
```
 Type Parameters:
 
 P - the payload type.
 
 Parameters:
 
 splitter - the splitter Function.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor, SplitterEndpointSpec
 - route
```
public <S,T> B route(java.util.function.Function<S,T> router)
```
 Populate the MethodInvokingRouter for provided Function with default options. Typically used with a Java 8 Lambda expression:
```
 .route(p -> p.equals("foo") || p.equals("bar") ? new String[] {"foo", "bar"} : null)
 
 
```
 Use route(Class, Function) if you need to access the entire message.
 Type Parameters:
 
 S - the source payload type.
 
 T - the target result type.
 
 Parameters:
 
 router - the Function to use.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 - route
```
public <S,T> B route(java.util.function.Function<S,T> router,
 java.util.function.Consumer<RouterSpec<T,MethodInvokingRouter>> routerConfigurer)
```
 Populate the MethodInvokingRouter for provided Function with provided options from RouterSpec. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .<Integer, Boolean>route(p -> p % 2 == 0,
 m -> m.channelMapping("true", "evenChannel")
 .subFlowMapping("false", f ->
 f.<Integer>handle((p, h) -> p * 3))
 .applySequence(false))
 
 
```
 Use route(Class, Function, Consumer) if you need to access the entire message.
 Type Parameters:
 
 S - the source payload type.
 
 T - the target result type.
 
 Parameters:
 
 router - the Function to use.
 
 routerConfigurer - the Consumer to provide MethodInvokingRouter options.
 
 Returns:
 
 the current IntegrationFlowDefinition.
 - fixedSubscriberChannel
```
public B fixedSubscriberChannel()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate an FixedSubscriberChannel instance at the current IntegrationFlow chain position. The 'bean name' will be generated during the bean registration phase.
 
 Overrides:
 
 fixedSubscriberChannel in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - fixedSubscriberChannel
```
public B fixedSubscriberChannel(String messageChannelName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate an FixedSubscriberChannel instance at the current IntegrationFlow chain position. The provided messageChannelName is used for the bean registration.
 
 Overrides:
 
 fixedSubscriberChannel in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageChannelName - the bean name to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - channel
```
public B channel(String messageChannelName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a MessageChannelReference instance at the current IntegrationFlow chain position. The provided messageChannelName is used for the bean registration (DirectChannel), if there is no such a bean in the application context. Otherwise the existing MessageChannel bean is used to wire integration endpoints.
 
 Overrides:
 
 channel in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageChannelName - the bean name to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - channel
```
public B channel(MessageChannelSpec<?,?> messageChannelSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a MessageChannel instance at the current IntegrationFlow chain position using the MessageChannelSpec fluent API.
 
 Overrides:
 
 channel in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageChannelSpec - the MessageChannelSpec to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MessageChannels
 - channel
```
public B channel(MessageChannel messageChannel)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided MessageChannel instance at the current IntegrationFlow chain position. The messageChannel can be an existing bean, or fresh instance, in which case the IntegrationFlowBeanPostProcessor will populate it as a bean with a generated name.
 
 Overrides:
 
 channel in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageChannel - the MessageChannel to populate.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - channel
```
public B channel(java.util.function.Function<Channels,MessageChannelSpec<?,?>> channels)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a MessageChannel instance at the current IntegrationFlow chain position using the Channels factory fluent API.
 
 Overrides:
 
 channel in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 channels - the Function to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - publishSubscribeChannel
```
public B publishSubscribeChannel(java.util.function.Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 The PublishSubscribeChannel BaseIntegrationFlowDefinition.channel(java.lang.String) method specific implementation to allow the use of the 'subflow' subscriber capability.
 
 Overrides:
 
 publishSubscribeChannel in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 publishSubscribeChannelConfigurer - the Consumer to specify PublishSubscribeSpec options including 'subflow' definition.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - publishSubscribeChannel
```
public B publishSubscribeChannel(Executor executor,
 java.util.function.Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 The PublishSubscribeChannel BaseIntegrationFlowDefinition.channel(java.lang.String) method specific implementation to allow the use of the 'subflow' subscriber capability. Use the provided Executor for the target subscribers.
 
 Overrides:
 
 publishSubscribeChannel in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 executor - the Executor to use.
 
 publishSubscribeChannelConfigurer - the Consumer to specify PublishSubscribeSpec options including 'subflow' definition.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - wireTap
```
public B wireTap(IntegrationFlow flow)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the Wire Tap EI Pattern specific ChannelInterceptor implementation to the current BaseIntegrationFlowDefinition.currentMessageChannel. It is useful when an implicit MessageChannel is used between endpoints:
```
 .filter("World"::equals)
 .wireTap(sf -> sf.<String, String>transform(String::toUpperCase))
 .handle(p -> process(p))
 
 
```
 This method can be used after any BaseIntegrationFlowDefinition.channel(java.lang.String) for explicit MessageChannel, but with the caution do not impact existing ChannelInterceptors.
 Overrides:
 
 wireTap in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 flow - the IntegrationFlow for wire-tap subflow as an alternative to the wireTapChannel.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - wireTap
```
public B wireTap(String wireTapChannel)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the Wire Tap EI Pattern specific ChannelInterceptor implementation to the current BaseIntegrationFlowDefinition.currentMessageChannel. It is useful when an implicit MessageChannel is used between endpoints:
```
 f -> f.wireTap("tapChannel")
 .handle(p -> process(p))
 
 
```
 This method can be used after any BaseIntegrationFlowDefinition.channel(java.lang.String) for explicit MessageChannel, but with the caution do not impact existing ChannelInterceptors.
 Overrides:
 
 wireTap in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 wireTapChannel - the MessageChannel bean name to wire-tap.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - wireTap
```
public B wireTap(MessageChannel wireTapChannel)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the Wire Tap EI Pattern specific ChannelInterceptor implementation to the current BaseIntegrationFlowDefinition.currentMessageChannel. It is useful when an implicit MessageChannel is used between endpoints:
```
 .transform("payload")
 .wireTap(tapChannel())
 .channel("foo")
 
 
```
 This method can be used after any BaseIntegrationFlowDefinition.channel(java.lang.String) for explicit MessageChannel, but with the caution do not impact existing ChannelInterceptors.
 Overrides:
 
 wireTap in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 wireTapChannel - the MessageChannel to wire-tap.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - wireTap
```
public B wireTap(IntegrationFlow flow,
 java.util.function.Consumer<WireTapSpec> wireTapConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the Wire Tap EI Pattern specific ChannelInterceptor implementation to the current BaseIntegrationFlowDefinition.currentMessageChannel. It is useful when an implicit MessageChannel is used between endpoints:
```
 .transform("payload")
 .wireTap(sf -> sf.<String, String>transform(String::toUpperCase), wt -> wt.selector("payload == 'foo'"))
 .channel("foo")
 
 
```
 This method can be used after any BaseIntegrationFlowDefinition.channel(java.lang.String) for explicit MessageChannel, but with the caution do not impact existing ChannelInterceptors.
 Overrides:
 
 wireTap in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 flow - the IntegrationFlow for wire-tap subflow as an alternative to the wireTapChannel.
 
 wireTapConfigurer - the Consumer to accept options for the WireTap.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - wireTap
```
public B wireTap(String wireTapChannel,
 java.util.function.Consumer<WireTapSpec> wireTapConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the Wire Tap EI Pattern specific ChannelInterceptor implementation to the current BaseIntegrationFlowDefinition.currentMessageChannel. It is useful when an implicit MessageChannel is used between endpoints:
```
 .transform("payload")
 .wireTap("tapChannel", wt -> wt.selector(m -> m.getPayload().equals("foo")))
 .channel("foo")
 
 
```
 This method can be used after any BaseIntegrationFlowDefinition.channel(java.lang.String) for explicit MessageChannel, but with the caution do not impact existing ChannelInterceptors.
 Overrides:
 
 wireTap in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 wireTapChannel - the MessageChannel bean name to wire-tap.
 
 wireTapConfigurer - the Consumer to accept options for the WireTap.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - wireTap
```
public B wireTap(MessageChannel wireTapChannel,
 java.util.function.Consumer<WireTapSpec> wireTapConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the Wire Tap EI Pattern specific ChannelInterceptor implementation to the current BaseIntegrationFlowDefinition.currentMessageChannel. It is useful when an implicit MessageChannel is used between endpoints:
```
 .transform("payload")
 .wireTap(tapChannel(), wt -> wt.selector(m -> m.getPayload().equals("foo")))
 .channel("foo")
 
 
```
 This method can be used after any BaseIntegrationFlowDefinition.channel(java.lang.String) for explicit MessageChannel, but with the caution do not impact existing ChannelInterceptors.
 Overrides:
 
 wireTap in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 wireTapChannel - the MessageChannel to wire-tap.
 
 wireTapConfigurer - the Consumer to accept options for the WireTap.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - wireTap
```
public B wireTap(WireTapSpec wireTapSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the Wire Tap EI Pattern specific ChannelInterceptor implementation to the current BaseIntegrationFlowDefinition.currentMessageChannel.
 It is useful when an implicit MessageChannel is used between endpoints:
```
 .transform("payload")
 .wireTap(new WireTap(tapChannel().selector(m -> m.getPayload().equals("foo")))
 .channel("foo")
 
 
```
 This method can be used after any BaseIntegrationFlowDefinition.channel(java.lang.String) for explicit MessageChannel, but with the caution do not impact existing ChannelInterceptors.
 Overrides:
 
 wireTap in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 wireTapSpec - the WireTapSpec to use.
 When this EIP-method is used in the end of flow, it appends nullChannel to terminate flow properly, Otherwise Dispatcher has no subscribers exception is thrown for implicit DirectChannel.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - controlBus
```
public B controlBus()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the Control Bus EI Pattern specific MessageHandler implementation at the current IntegrationFlow chain position.
 
 Overrides:
 
 controlBus in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ExpressionCommandMessageProcessor
 - controlBus
```
public B controlBus(java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the Control Bus EI Pattern specific MessageHandler implementation at the current IntegrationFlow chain position.
 
 Overrides:
 
 controlBus in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 endpointConfigurer - the Consumer to accept integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ExpressionCommandMessageProcessor, GenericEndpointSpec
 - transform
```
public B transform(String expression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the Transformer EI Pattern specific MessageHandler implementation for the SpEL Expression.
 
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 expression - the Transformer Expression.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ExpressionEvaluatingTransformer
 - transform
```
public B transform(String expression,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the Transformer EI Pattern specific MessageHandler implementation for the SpEL Expression.
 
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 expression - the Transformer Expression.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ExpressionEvaluatingTransformer
 - transform
```
public B transform(Object service)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the MethodInvokingTransformer to invoke the discovered service method at runtime.
 
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ExpressionEvaluatingTransformer
 - transform
```
public B transform(Object service,
 String methodName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the MethodInvokingTransformer to invoke the service method at runtime.
 
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer
 - transform
```
public B transform(Object service,
 String methodName,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the MethodInvokingTransformer to invoke the service method at runtime.
 
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ExpressionEvaluatingTransformer
 - transform
```
public B transform(MessageProcessorSpec<?> messageProcessorSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MessageTransformingHandler instance for the MessageProcessor from provided MessageProcessorSpec.
```
 .transform(Scripts.script("classpath:myScript.py").variable("foo", bar()))
 
 
```
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer
 - transform
```
public B transform(MessageProcessorSpec<?> messageProcessorSpec,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MessageTransformingHandler instance for the MessageProcessor from provided MessageProcessorSpec. In addition accept options for the integration endpoint using GenericEndpointSpec.
```
 .transform(Scripts.script("classpath:myScript.py").variable("foo", bar()),
 e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer
 - convert
```
public  B convert(Class payloadType)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler instance for the provided payloadType to convert at runtime.
 
 Overrides:
 
 convert in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type - 'convert to'.
 
 Parameters:
 
 payloadType - the Class for expected payload type.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer, LambdaMessageProcessor
 - transform
```
public <P,T> B transform(Class payloadType,
 GenericTransformer<P,T> genericTransformer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler instance for the provided GenericTransformer for the specific payloadType to convert at runtime.
 
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type - 'transform from' or Message.class.
 
 T - the target type - 'transform to'.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the transformer. Conversion to this type will be attempted, if necessary.
 
 genericTransformer - the GenericTransformer to populate.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer, LambdaMessageProcessor
 - convert
```
public  B convert(Class payloadType,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler instance for the provided payloadType to convert at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 convert in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type - 'transform to'.
 
 Parameters:
 
 payloadType - the Class for expected payload type.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpec
 - transform
```
public <P,T> B transform(Class payloadType,
 GenericTransformer<P,T> genericTransformer,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler instance for the provided GenericTransformer for the specific payloadType to convert at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 transform in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type - 'transform from', or Message.class.
 
 T - the target type - 'transform to'.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the transformer. Conversion to this type will be attempted, if necessary.
 
 genericTransformer - the GenericTransformer to populate.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpec
 - filter
```
public B filter(String expression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a MessageFilter with MessageSelector for the provided SpEL expression.
 
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 expression - the SpEL expression.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - filter
```
public B filter(String expression,
 java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageFilter with MessageSelector for the provided SpEL expression. In addition accept options for the integration endpoint using FilterEndpointSpec:
```
 .filter("payload.hot"), e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 expression - the SpEL expression.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 FilterEndpointSpec
 - filter
```
public B filter(Object service)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a MessageFilter with MethodInvokingSelector for the discovered method of the provided service.
 
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingSelector
 - filter
```
public B filter(Object service,
 String methodName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a MessageFilter with MethodInvokingSelector for the method of the provided service.
 
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingSelector
 - filter
```
public B filter(Object service,
 String methodName,
 java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a MessageFilter with MethodInvokingSelector for the method of the provided service.
 
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingSelector
 - filter
```
public B filter(MessageProcessorSpec<?> messageProcessorSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageFilter with MethodInvokingSelector for the MessageProcessor from the provided MessageProcessorSpec.
```
 .filter(Scripts.script(scriptResource).lang("ruby"))
 
 
```
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - filter
```
public B filter(MessageProcessorSpec<?> messageProcessorSpec,
 java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageFilter with MethodInvokingSelector for the MessageProcessor from the provided MessageProcessorSpec. In addition accept options for the integration endpoint using FilterEndpointSpec.
```
 .filter(Scripts.script(scriptResource).lang("ruby"),
 e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - filter
```
public  B filter(Class payloadType,
 GenericSelector genericSelector)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageFilter with MethodInvokingSelector for the provided GenericSelector. Typically used with a Java 8 Lambda expression:
```
 .filter(Date.class, p -> p.after(new Date()))
 
 
```
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the source payload type or Message.class.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the selector. Conversion to this type will be attempted, if necessary.
 
 genericSelector - the GenericSelector to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor
 - filter
```
public  B filter(Class payloadType,
 GenericSelector genericSelector,
 java.util.function.Consumer<FilterEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageFilter with MethodInvokingSelector for the provided GenericSelector. In addition accept options for the integration endpoint using FilterEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .filter(Date.class, p -> p.after(new Date()), e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 filter in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the source payload type or Message.class.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the selector. Conversion to this type will be attempted, if necessary.
 
 genericSelector - the GenericSelector to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor, FilterEndpointSpec
 - handle
```
public <H extends MessageHandler> B handle(MessageHandlerSpec<?,H> messageHandlerSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the selected protocol specific MessageHandler implementation from Namespace Factory:
```
 .handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"))
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 H - the target MessageHandler type.
 
 Parameters:
 
 messageHandlerSpec - the MessageHandlerSpec to configure protocol specific MessageHandler.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public B handle(MessageHandler messageHandler)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the provided MessageHandler implementation. Can be used as Java 8 Lambda expression:
```
 .handle(m -> logger.info(m.getPayload())
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageHandler - the MessageHandler to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public B handle(String beanName,
 String methodName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the method for provided bean at runtime.
 
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 beanName - the bean name to use.
 
 methodName - the method to invoke.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public B handle(String beanName,
 String methodName,
 java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the method for provided bean at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 beanName - the bean name to use.
 
 methodName - the method to invoke.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public B handle(Object service)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the discovered method for provided service at runtime.
 
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service object to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public B handle(Object service,
 String methodName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the method for provided bean at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service object to use.
 
 methodName - the method to invoke.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public B handle(Object service,
 String methodName,
 java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the method for provided bean at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service object to use.
 
 methodName - the method to invoke.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public  B handle(Class payloadType,
 GenericHandler handler)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the provided GenericHandler at runtime. Typically used with a Java 8 Lambda expression:
```
 .handle(Integer.class, (p, h) -> p / 2)
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type to expect, or Message.class.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the handler. Conversion to this type will be attempted, if necessary.
 
 handler - the handler to invoke.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor
 - handle
```
public  B handle(Class payloadType,
 GenericHandler handler,
 java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the provided GenericHandler at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .handle(Integer.class, (p, h) -> p / 2, e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type to expect or Message.class.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the handler. Conversion to this type will be attempted, if necessary.
 
 handler - the handler to invoke.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor
 - handle
```
public B handle(MessageProcessorSpec<?> messageProcessorSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the MessageProcessor from the provided MessageProcessorSpec.
```
 .handle(Scripts.script("classpath:myScript.ruby"))
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public B handle(MessageProcessorSpec<?> messageProcessorSpec,
 java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the MessageProcessor from the provided MessageProcessorSpec. In addition accept options for the integration endpoint using GenericEndpointSpec.
```
 .handle(Scripts.script("classpath:myScript.ruby"), e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public <H extends MessageHandler> B handle(MessageHandlerSpec<?,H> messageHandlerSpec,
 java.util.function.Consumer<GenericEndpointSpec<H>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the selected protocol specific MessageHandler implementation from Namespace Factory: In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"),
 e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 H - the MessageHandler type.
 
 Parameters:
 
 messageHandlerSpec - the MessageHandlerSpec to configure protocol specific MessageHandler.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - handle
```
public <H extends MessageHandler> B handle(H messageHandler,
 java.util.function.Consumer<GenericEndpointSpec<H>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ServiceActivatingHandler for the provided MessageHandler implementation. In addition accept options for the integration endpoint using GenericEndpointSpec. Can be used as Java 8 Lambda expression:
```
 .handle(m -> logger.info(m.getPayload()), e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 handle in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 H - the MessageHandler type.
 
 Parameters:
 
 messageHandler - the MessageHandler to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - bridge
```
public B bridge()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a BridgeHandler to the current integration flow position.
 
 Overrides:
 
 bridge in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.bridge(Consumer)
 - bridge
```
public B bridge(java.util.function.Consumer<GenericEndpointSpec<BridgeHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a BridgeHandler to the current integration flow position. Typically used with a Java 8 Lambda expression:
```
 .bridge(s -> s.poller(Pollers.fixedDelay(100))
 .autoStartup(false)
 .id("priorityChannelBridge"))
 
 
```
 Overrides:
 
 bridge in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 GenericEndpointSpec
 - delay
```
public B delay(String groupId)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a DelayHandler to the current integration flow position with default options.
 
 Overrides:
 
 delay in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 groupId - the groupId for delayed messages in the MessageGroupStore.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - delay
```
public B delay(String groupId,
 java.util.function.Consumer<DelayerEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a DelayHandler to the current integration flow position.
 
 Overrides:
 
 delay in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 groupId - the groupId for delayed messages in the MessageGroupStore.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 DelayerEndpointSpec
 - enrich
```
public B enrich(java.util.function.Consumer<EnricherSpec> enricherConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a ContentEnricher to the current integration flow position with provided options. Typically used with a Java 8 Lambda expression:
```
 .enrich(e -> e.requestChannel("enrichChannel")
 .requestPayload(Message::getPayload)
 .shouldClonePayload(false)
 .autoStartup(false)
 .<Map<String, String>>headerFunction("foo", m -> m.getPayload().get("name")))
 
 
```
 Overrides:
 
 enrich in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 enricherConfigurer - the Consumer to provide ContentEnricher options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 EnricherSpec
 - enrichHeaders
```
public B enrichHeaders(MapBuilder<?,String,Object> headers)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageTransformingHandler for a HeaderEnricher using header values from provided MapBuilder. Can be used together with Namespace Factory:
```
 .enrichHeaders(Mail.headers()
 .subjectFunction(m -> "foo")
 .from("foo@bar")
 .toFunction(m -> new String[] {"bar@baz"}))
 
 
```
 Overrides:
 
 enrichHeaders in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headers - the MapBuilder to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - enrichHeaders
```
public B enrichHeaders(MapBuilder<?,String,Object> headers,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageTransformingHandler for a HeaderEnricher using header values from provided MapBuilder. In addition accept options for the integration endpoint using GenericEndpointSpec. Can be used together with Namespace Factory:
```
 .enrichHeaders(Mail.headers()
 .subjectFunction(m -> "foo")
 .from("foo@bar")
 .toFunction(m -> new String[] {"bar@baz"}),
 e -> e.autoStartup(false))
 
 
```
 Overrides:
 
 enrichHeaders in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headers - the MapBuilder to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 GenericEndpointSpec
 - enrichHeaders
```
public B enrichHeaders(Map<String,Object> headers,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Accept a Map of values to be used for the Message header enrichment. values can apply an Expression to be evaluated against a request Message.
 
 Overrides:
 
 enrichHeaders in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headers - the Map of headers to enrich.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 GenericEndpointSpec
 - enrichHeaders
```
public B enrichHeaders(java.util.function.Consumer<HeaderEnricherSpec> headerEnricherConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate a MessageTransformingHandler for a HeaderEnricher as the result of provided Consumer. Typically used with a Java 8 Lambda expression:
```
 .enrichHeaders(h -> h.header(FileHeaders.FILENAME, "foo.sitest")
 .header("directory", new File(tmpDir, "fileWritingFlow")))
 
 
```
 Overrides:
 
 enrichHeaders in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headerEnricherConfigurer - the Consumer to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 HeaderEnricherSpec
 - split
```
public B split()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the DefaultMessageSplitter with default options to the current integration flow position.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - split
```
public B split(java.util.function.Consumer<SplitterEndpointSpec<DefaultMessageSplitter>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the DefaultMessageSplitter with provided options to the current integration flow position. Typically used with a Java 8 Lambda expression:
```
 .split(s -> s.applySequence(false).delimiters(","))
 
 
```
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 endpointConfigurer - the Consumer to provide integration endpoint options and for DefaultMessageSplitter.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public B split(String expression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the ExpressionEvaluatingSplitter with provided SpEL expression.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 expression - the splitter SpEL expression. and for ExpressionEvaluatingSplitter.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public B split(String expression,
 java.util.function.Consumer<SplitterEndpointSpec<ExpressionEvaluatingSplitter>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the ExpressionEvaluatingSplitter with provided SpEL expression.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 expression - the splitter SpEL expression.
 
 endpointConfigurer - the Consumer to provide integration endpoint options and for ExpressionEvaluatingSplitter.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public B split(Object service)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingSplitter to evaluate the discovered method of the service at runtime.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingSplitter
 - split
```
public B split(Object service,
 String methodName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingSplitter to evaluate the provided method of the service at runtime.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingSplitter
 - split
```
public B split(Object service,
 String methodName,
 java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingSplitter to evaluate the provided method of the bean at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke.
 
 endpointConfigurer - the Consumer to provide integration endpoint options and for MethodInvokingSplitter.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec, MethodInvokingSplitter
 - split
```
public B split(String beanName,
 String methodName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingSplitter to evaluate the provided method of the bean at runtime.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 beanName - the bean name to use.
 
 methodName - the method to invoke at runtime.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - split
```
public B split(String beanName,
 String methodName,
 java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingSplitter to evaluate the provided method of the bean at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 beanName - the bean name to use.
 
 methodName - the method to invoke at runtime.
 
 endpointConfigurer - the Consumer to provide integration endpoint options and for MethodInvokingSplitter.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public B split(MessageProcessorSpec<?> messageProcessorSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingSplitter to evaluate the MessageProcessor at runtime from provided MessageProcessorSpec.
```
 .split(Scripts.script("classpath:myScript.ruby"))
 
 
```
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the splitter MessageProcessorSpec.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public B split(MessageProcessorSpec<?> messageProcessorSpec,
 java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingSplitter to evaluate the MessageProcessor at runtime from provided MessageProcessorSpec. In addition accept options for the integration endpoint using GenericEndpointSpec.
```
 .split(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000),
 			, e -> e.applySequence(false))
 
 
```
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the splitter MessageProcessorSpec.
 
 endpointConfigurer - the Consumer to provide integration endpoint options and for MethodInvokingSplitter.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public  B split(Class payloadType,
 java.util.function.Function<P,?> splitter)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingSplitter to evaluate the provided Function at runtime. Typically used with a Java 8 Lambda expression:
```
 .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)))))
 
 
```
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type or Message.class.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the splitter. Conversion to this type will be attempted, if necessary.
 
 splitter - the splitter Function.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor
 - split
```
public  B split(Class payloadType,
 java.util.function.Function<P,?> splitter,
 java.util.function.Consumer<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingSplitter to evaluate the provided Function at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .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))
 
 
```
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the payload type or Message.class.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the splitter. Conversion to this type will be attempted, if necessary.
 
 splitter - the splitter Function.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor, SplitterEndpointSpec
 - split
```
public <S extends AbstractMessageSplitter> B split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided AbstractMessageSplitter to the current integration flow position.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 S - the AbstractMessageSplitter
 
 Parameters:
 
 splitterMessageHandlerSpec - the MessageHandlerSpec to populate.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public <S extends AbstractMessageSplitter> B split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec,
 java.util.function.Consumer<SplitterEndpointSpec<S>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided AbstractMessageSplitter to the current integration flow position.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 S - the AbstractMessageSplitter
 
 Parameters:
 
 splitterMessageHandlerSpec - the MessageHandlerSpec to populate.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public B split(AbstractMessageSplitter splitter)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided AbstractMessageSplitter to the current integration flow position.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 splitter - the AbstractMessageSplitter to populate.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - split
```
public <S extends AbstractMessageSplitter> B split(S splitter,
 java.util.function.Consumer<SplitterEndpointSpec<S>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided AbstractMessageSplitter to the current integration flow position.
 
 Overrides:
 
 split in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 S - the AbstractMessageSplitter
 
 Parameters:
 
 splitter - the AbstractMessageSplitter to populate.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 SplitterEndpointSpec
 - headerFilter
```
public B headerFilter(String... headersToRemove)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Provide the HeaderFilter to the current StandardIntegrationFlow.
 
 Overrides:
 
 headerFilter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headersToRemove - the array of headers (or patterns) to remove from MessageHeaders.
 
 Returns:
 
 this BaseIntegrationFlowDefinition.
 - headerFilter
```
public B headerFilter(String headersToRemove,
 boolean patternMatch)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Provide the HeaderFilter to the current StandardIntegrationFlow.
 
 Overrides:
 
 headerFilter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headersToRemove - the comma separated headers (or patterns) to remove from MessageHeaders.
 
 patternMatch - the boolean flag to indicate if headersToRemove should be interpreted as patterns or direct header names.
 
 Returns:
 
 this BaseIntegrationFlowDefinition.
 - headerFilter
```
public B headerFilter(HeaderFilter headerFilter,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided MessageTransformingHandler for the provided HeaderFilter.
 
 Overrides:
 
 headerFilter in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headerFilter - the HeaderFilter to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 GenericEndpointSpec
 - claimCheckIn
```
public B claimCheckIn(MessageStore messageStore)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore.
 
 Overrides:
 
 claimCheckIn in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageStore - the MessageStore to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - claimCheckIn
```
public B claimCheckIn(MessageStore messageStore,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 claimCheckIn in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageStore - the MessageStore to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 GenericEndpointSpec
 - claimCheckOut
```
public B claimCheckOut(MessageStore messageStore)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore. The removeMessage option of ClaimCheckOutTransformer is to false.
 
 Overrides:
 
 claimCheckOut in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageStore - the MessageStore to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - claimCheckOut
```
public B claimCheckOut(MessageStore messageStore,
 boolean removeMessage)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore and removeMessage flag.
 
 Overrides:
 
 claimCheckOut in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageStore - the MessageStore to use.
 
 removeMessage - the removeMessage boolean flag.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ClaimCheckOutTransformer.setRemoveMessage(boolean)
 - claimCheckOut
```
public B claimCheckOut(MessageStore messageStore,
 boolean removeMessage,
 java.util.function.Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore and removeMessage flag. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 claimCheckOut in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageStore - the MessageStore to use.
 
 removeMessage - the removeMessage boolean flag.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 GenericEndpointSpec, ClaimCheckOutTransformer.setRemoveMessage(boolean)
 - resequence
```
public B resequence()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the ResequencingMessageHandler with default options.
 
 Overrides:
 
 resequence in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - resequence
```
public B resequence(java.util.function.Consumer<ResequencerSpec> resequencer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the ResequencingMessageHandler with provided options from ResequencerSpec. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .resequence(r -> r.releasePartialSequences(true)
 .correlationExpression("'foo'")
 .phase(100))
 
 
```
 Overrides:
 
 resequence in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 resequencer - the Consumer to provide ResequencingMessageHandler options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ResequencerSpec
 - aggregate
```
public B aggregate()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the AggregatingMessageHandler with default options.
 
 Overrides:
 
 aggregate in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - aggregate
```
public B aggregate(java.util.function.Consumer<AggregatorSpec> aggregator)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the AggregatingMessageHandler with provided options from AggregatorSpec. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .aggregate(a -> a.correlationExpression("1")
 .releaseStrategy(g -> g.size() == 25)
 .phase(100))
 
 
```
 Overrides:
 
 aggregate in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 aggregator - the Consumer to provide AggregatingMessageHandler options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 AggregatorSpec
 - route
```
public B route(String beanName,
 String method)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingRouter for provided bean and its method with default options.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 beanName - the bean to use.
 
 method - the method to invoke at runtime.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - route
```
public B route(String beanName,
 String method,
 java.util.function.Consumer<RouterSpec<Object,MethodInvokingRouter>> routerConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingRouter for provided bean and its method with provided options from RouterSpec.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 beanName - the bean to use.
 
 method - the method to invoke at runtime.
 
 routerConfigurer - the Consumer to provide MethodInvokingRouter options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - route
```
public B route(Object service)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingRouter for the discovered method of the provided service and its method with default options.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the bean to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingRouter
 - route
```
public B route(Object service,
 String methodName)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingRouter for the method of the provided service and its method with default options.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingRouter
 - route
```
public B route(Object service,
 String methodName,
 java.util.function.Consumer<RouterSpec<Object,MethodInvokingRouter>> routerConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the MethodInvokingRouter for the method of the provided service and its method with provided options from RouterSpec.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 service - the service to use.
 
 methodName - the method to invoke.
 
 routerConfigurer - the Consumer to provide MethodInvokingRouter options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 MethodInvokingRouter
 - route
```
public B route(String expression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the ExpressionEvaluatingRouter for provided SpEL expression with default options.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 expression - the expression to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - route
```
public <T> B route(String expression,
 java.util.function.Consumer<RouterSpec<T,ExpressionEvaluatingRouter>> routerConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the ExpressionEvaluatingRouter for provided SpEL expression with provided options from RouterSpec.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 T - the target result type.
 
 Parameters:
 
 expression - the expression to use.
 
 routerConfigurer - the Consumer to provide ExpressionEvaluatingRouter options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - route
```
public <S,T> B route(Class<S> payloadType,
 java.util.function.Function<S,T> router)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingRouter for provided Function and payload type with default options. Typically used with a Java 8 Lambda expression:
```
 .route(Integer.class, p -> p % 2 == 0)
 
 
```
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 S - the source payload type or Message.class.
 
 T - the target result type.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the splitter. Conversion to this type will be attempted, if necessary.
 
 router - the Function to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor
 - route
```
public <P,T> B route(Class payloadType,
 java.util.function.Function<P,T> router,
 java.util.function.Consumer<RouterSpec<T,MethodInvokingRouter>> routerConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingRouter for provided Function and payload type and options from RouterSpec. In addition accept options for the integration endpoint using GenericEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .route(Integer.class, p -> p % 2 == 0,
					m -> m.channelMapping("true", "evenChannel")
 .subFlowMapping("false", f ->
 f.<Integer>handle((p, h) -> p * 3))
 .applySequence(false))
 
 
```
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the source payload type or Message.class.
 
 T - the target result type.
 
 Parameters:
 
 payloadType - the Class for expected payload type. It can also be Message.class if you wish to access the entire message in the splitter. Conversion to this type will be attempted, if necessary.
 
 router - the Function to use.
 
 routerConfigurer - the Consumer to provide MethodInvokingRouter options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 LambdaMessageProcessor
 - route
```
public B route(MessageProcessorSpec<?> messageProcessorSpec)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingRouter for the MessageProcessor from the provided MessageProcessorSpec with default options.
```
 .route(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000))
 
 
```
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - route
```
public B route(MessageProcessorSpec<?> messageProcessorSpec,
 java.util.function.Consumer<RouterSpec<Object,MethodInvokingRouter>> routerConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the MethodInvokingRouter for the MessageProcessor from the provided MessageProcessorSpec with default options.
```
 .route(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000),
 m -> m.channelMapping("true", "evenChannel")
 .subFlowMapping("false", f ->
 f.<Integer>handle((p, h) -> p * 3)))
 
 
```
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 messageProcessorSpec - the MessageProcessorSpec to use.
 
 routerConfigurer - the Consumer to provide MethodInvokingRouter options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - routeToRecipients
```
public B routeToRecipients(java.util.function.Consumer<RecipientListRouterSpec> routerConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the RecipientListRouter with options from the RecipientListRouterSpec. Typically used with a Java 8 Lambda expression:
```
 .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"))))
 
 
```
 Overrides:
 
 routeToRecipients in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 routerConfigurer - the Consumer to provide RecipientListRouter options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - routeByException
```
public B routeByException(java.util.function.Consumer<RouterSpec<Class<? extends Throwable>,ErrorMessageExceptionTypeRouter>> routerConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the ErrorMessageExceptionTypeRouter with options from the RouterSpec. Typically used with a Java 8 Lambda expression:
```
 .routeByException(r -> r
 .channelMapping(IllegalArgumentException.class, "illegalArgumentChannel")
 .subFlowMapping(MessageHandlingException.class, sf ->
 sf.handle(...))
 )
 
 
```
 Overrides:
 
 routeByException in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 routerConfigurer - the Consumer to provide ErrorMessageExceptionTypeRouter options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 ErrorMessageExceptionTypeRouter
 - route
```
public B route(AbstractMessageRouter router)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided AbstractMessageRouter implementation to the current integration flow position.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 router - the AbstractMessageRouter to populate.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - route
```
public <R extends AbstractMessageRouter> B route(R router,
 java.util.function.Consumer<GenericEndpointSpec<R>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the provided AbstractMessageRouter implementation to the current integration flow position. In addition accept options for the integration endpoint using GenericEndpointSpec.
 
 Overrides:
 
 route in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 R - the AbstractMessageRouter type.
 
 Parameters:
 
 router - the AbstractMessageRouter to populate.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - gateway
```
public B gateway(String requestChannel)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the "artificial" GatewayMessageHandler for the provided requestChannel to send a request with default options. Uses RequestReplyExchanger Proxy on the background.
 
 Overrides:
 
 gateway in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 requestChannel - the MessageChannel bean name.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - gateway
```
public B gateway(String requestChannel,
 java.util.function.Consumer<GatewayEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the "artificial" GatewayMessageHandler for the provided requestChannel to send a request with options from GatewayEndpointSpec. Uses RequestReplyExchanger Proxy on the background.
 
 Overrides:
 
 gateway in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 requestChannel - the MessageChannel bean name.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - gateway
```
public B gateway(MessageChannel requestChannel)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the "artificial" GatewayMessageHandler for the provided requestChannel to send a request with default options. Uses RequestReplyExchanger Proxy on the background.
 
 Overrides:
 
 gateway in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 requestChannel - the MessageChannel to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - gateway
```
public B gateway(MessageChannel requestChannel,
 java.util.function.Consumer<GatewayEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate the "artificial" GatewayMessageHandler for the provided requestChannel to send a request with options from GatewayEndpointSpec. Uses RequestReplyExchanger Proxy on the background.
 
 Overrides:
 
 gateway in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 requestChannel - the MessageChannel to use.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - gateway
```
public B gateway(IntegrationFlow flow)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the "artificial" GatewayMessageHandler for the provided subflow. Typically used with a Java 8 Lambda expression:
```
 .gateway(f -> f.transform("From Gateway SubFlow: "::concat))
 
 
```
 Overrides:
 
 gateway in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 flow - the IntegrationFlow to to send a request message and wait for reply.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - gateway
```
public B gateway(IntegrationFlow flow,
 java.util.function.Consumer<GatewayEndpointSpec> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 Populate the "artificial" GatewayMessageHandler for the provided subflow with options from GatewayEndpointSpec. Typically used with a Java 8 Lambda expression:
```
 .gateway(f -> f.transform("From Gateway SubFlow: "::concat), e -> e.replyTimeout(100L))
 
 
```
 Overrides:
 
 gateway in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 flow - the IntegrationFlow to to send a request message and wait for reply.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - log
```
public B log()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO logging level and org.springframework.integration.handler.LoggingHandler as a default logging category.
 The full request Message will be logged.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(LoggingHandler.Level level)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for provided LoggingHandler.Level logging level and org.springframework.integration.handler.LoggingHandler as a default logging category.
 The full request Message will be logged.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(String category)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided logging category and INFO logging level.
 The full request Message will be logged.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 category - the logging category to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(LoggingHandler.Level level,
 String category)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level and logging category.
 The full request Message will be logged.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category to use.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(LoggingHandler.Level level,
 String category,
 String logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, logging category and SpEL expression for the log message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category.
 
 logExpression - the SpEL expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public  B log(java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and Function for the log message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and SpEL expression to evaluate logger message at runtime against the request Message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(LoggingHandler.Level level,
 Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and SpEL expression to evaluate logger message at runtime against the request Message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(String category,
 Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO LoggingHandler.Level logging level, the provided logging category and SpEL expression to evaluate logger message at runtime against the request Message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 category - the logging category.
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public  B log(LoggingHandler.Level level,
 java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and Function for the log message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public  B log(String category,
 java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, the provided logging category and Function for the log message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 category - the logging category.
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public  B log(LoggingHandler.Level level,
 String category,
 java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, logging category and Function for the log message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category.
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - log
```
public B log(LoggingHandler.Level level,
 String category,
 Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, logging category and SpEL expression for the log message.
 When this operator is used in the end of flow, it is treated as one-way handler without any replies to continue. The BaseIntegrationFlowDefinition.logAndReply() should be used for request-reply configuration.
 
 Overrides:
 
 log in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category.
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 
 See Also:
 
 BaseIntegrationFlowDefinition.wireTap(WireTapSpec)
 - logAndReply
```
public IntegrationFlow logAndReply()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO logging level and org.springframework.integration.handler.LoggingHandler as a default logging category.
 The full request Message will be logged.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(LoggingHandler.Level level)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for provided LoggingHandler.Level logging level and org.springframework.integration.handler.LoggingHandler as a default logging category.
 The full request Message will be logged.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(String category)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided logging category and INFO logging level.
 The full request Message will be logged.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 category - the logging category to use.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(LoggingHandler.Level level,
 String category)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level and logging category.
 The full request Message will be logged.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category to use.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(LoggingHandler.Level level,
 String category,
 String logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, logging category and SpEL expression for the log message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category.
 
 logExpression - the SpEL expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public  IntegrationFlow logAndReply(java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and Function for the log message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and SpEL expression to evaluate logger message at runtime against the request Message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(LoggingHandler.Level level,
 Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and SpEL expression to evaluate logger message at runtime against the request Message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(String category,
 Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the INFO LoggingHandler.Level logging level, the provided logging category and SpEL expression to evaluate logger message at runtime against the request Message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 category - the logging category.
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public  IntegrationFlow logAndReply(LoggingHandler.Level level,
 java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, the org.springframework.integration.handler.LoggingHandler as a default logging category and Function for the log message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public  IntegrationFlow logAndReply(String category,
 java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, the provided logging category and Function for the log message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 category - the logging category.
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public  IntegrationFlow logAndReply(LoggingHandler.Level level,
 String category,
 java.util.function.Function<Message,Object> function)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, logging category and Function for the log message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 P - the expected payload type. against the request Message.
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category.
 
 function - the function to evaluate logger message at runtime
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - logAndReply
```
public IntegrationFlow logAndReply(LoggingHandler.Level level,
 String category,
 Expression logExpression)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a WireTap for the BaseIntegrationFlowDefinition.currentMessageChannel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, logging category and SpEL expression for the log message.
 A BaseIntegrationFlowDefinition.bridge() is added after this operator to make the flow reply-producing if the replyChannel header is present.
 This operator can be used only in the end of flow.
 
 Overrides:
 
 logAndReply in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 level - the LoggingHandler.Level.
 
 category - the logging category.
 
 logExpression - the Expression to evaluate logger message at runtime against the request Message.
 
 Returns:
 
 an IntegrationFlow instance based on this builder.
 
 See Also:
 
 BaseIntegrationFlowDefinition.log(), BaseIntegrationFlowDefinition.bridge()
 - scatterGather
```
public B scatterGather(MessageChannel scatterChannel)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ScatterGatherHandler to the current integration flow position based on the provided MessageChannel for scattering function and default AggregatorSpec for gathering function.
 
 Overrides:
 
 scatterGather in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 scatterChannel - the MessageChannel for scatting requests.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - scatterGather
```
public B scatterGather(MessageChannel scatterChannel,
 java.util.function.Consumer<AggregatorSpec> gatherer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ScatterGatherHandler to the current integration flow position based on the provided MessageChannel for scattering function and AggregatorSpec for gathering function.
 
 Overrides:
 
 scatterGather in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 scatterChannel - the MessageChannel for scatting requests.
 
 gatherer - the Consumer for AggregatorSpec to configure gatherer. Can be null.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - scatterGather
```
public B scatterGather(MessageChannel scatterChannel,
 java.util.function.Consumer<AggregatorSpec> gatherer,
 java.util.function.Consumer<ScatterGatherSpec> scatterGather)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ScatterGatherHandler to the current integration flow position based on the provided MessageChannel for scattering function and AggregatorSpec for gathering function.
 
 Overrides:
 
 scatterGather in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 scatterChannel - the MessageChannel for scatting requests.
 
 gatherer - the Consumer for AggregatorSpec to configure gatherer. Can be null.
 
 scatterGather - the Consumer for ScatterGatherSpec to configure ScatterGatherHandler and its endpoint. Can be null.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - scatterGather
```
public B scatterGather(java.util.function.Consumer<RecipientListRouterSpec> scatterer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ScatterGatherHandler to the current integration flow position based on the provided RecipientListRouterSpec for scattering function and default AggregatorSpec for gathering function.
 
 Overrides:
 
 scatterGather in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 scatterer - the Consumer for RecipientListRouterSpec to configure scatterer.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - scatterGather
```
public B scatterGather(java.util.function.Consumer<RecipientListRouterSpec> scatterer,
 java.util.function.Consumer<AggregatorSpec> gatherer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ScatterGatherHandler to the current integration flow position based on the provided RecipientListRouterSpec for scattering function and AggregatorSpec for gathering function.
 
 Overrides:
 
 scatterGather in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 scatterer - the Consumer for RecipientListRouterSpec to configure scatterer. Can be null.
 
 gatherer - the Consumer for AggregatorSpec to configure gatherer. Can be null.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - scatterGather
```
public B scatterGather(java.util.function.Consumer<RecipientListRouterSpec> scatterer,
 java.util.function.Consumer<AggregatorSpec> gatherer,
 java.util.function.Consumer<ScatterGatherSpec> scatterGather)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ScatterGatherHandler to the current integration flow position based on the provided RecipientListRouterSpec for scattering function and AggregatorSpec for gathering function.
 
 Overrides:
 
 scatterGather in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 scatterer - the Consumer for RecipientListRouterSpec to configure scatterer.
 
 gatherer - the Consumer for AggregatorSpec to configure gatherer.
 
 scatterGather - the Consumer for ScatterGatherSpec to configure ScatterGatherHandler and its endpoint. Can be null.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - barrier
```
public B barrier(long timeout)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a BarrierMessageHandler instance for provided timeout.
 
 Overrides:
 
 barrier in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 timeout - the timeout in milliseconds.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - barrier
```
public B barrier(long timeout,
 java.util.function.Consumer<BarrierSpec> barrierConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a BarrierMessageHandler instance for provided timeout and options from BarrierSpec and endpoint options from GenericEndpointSpec.
 
 Overrides:
 
 barrier in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 timeout - the timeout in milliseconds.
 
 barrierConfigurer - the Consumer to provide BarrierMessageHandler options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - trigger
```
public B trigger(String triggerActionId)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler instance to perform MessageTriggerAction.
 
 Overrides:
 
 trigger in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 triggerActionId - the MessageTriggerAction bean id.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - trigger
```
public B trigger(String triggerActionId,
 java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler instance to perform MessageTriggerAction and endpoint options from GenericEndpointSpec.
 
 Overrides:
 
 trigger in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 triggerActionId - the MessageTriggerAction bean id.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - trigger
```
public B trigger(MessageTriggerAction triggerAction)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler instance to perform MessageTriggerAction.
 
 Overrides:
 
 trigger in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 triggerAction - the MessageTriggerAction.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - trigger
```
public B trigger(MessageTriggerAction triggerAction,
 java.util.function.Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a ServiceActivatingHandler instance to perform MessageTriggerAction and endpoint options from GenericEndpointSpec.
 
 Overrides:
 
 trigger in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 triggerAction - the MessageTriggerAction.
 
 endpointConfigurer - the Consumer to provide integration endpoint options.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - fluxTransform
```
public <I,O> B fluxTransform(java.util.function.Function<? super reactor.core.publisher.Flux<Message>,? extends org.reactivestreams.Publisher<O>> fluxFunction)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Populate a FluxMessageChannel to start a reactive processing for upstream data, wrap it to a Flux, apply provided Function via Flux.transform(Function) and emit the result to one more FluxMessageChannel, subscribed in the downstream flow.
 
 Overrides:
 
 fluxTransform in class BaseIntegrationFlowDefinition>
 
 Type Parameters:
 
 I - the input payload type.
 
 O - the output type.
 
 Parameters:
 
 fluxFunction - the Function to process data reactive manner.
 
 Returns:
 
 the current BaseIntegrationFlowDefinition.
 - nullChannel
```
public IntegrationFlow nullChannel()
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Add a bean into this flow definition as a terminal operator.
 
 Overrides:
 
 nullChannel in class BaseIntegrationFlowDefinition>
 
 Returns:
 
 The IntegrationFlow instance based on this definition.
 - enrichHeaders
```
public B enrichHeaders(Map<String,Object> headers)
```
 Description copied from class: BaseIntegrationFlowDefinition
 
 Accept a Map of values to be used for the Message header enrichment. values can apply an Expression to be evaluated against a request Message.
 
 Overrides:
 
 enrichHeaders in class BaseIntegrationFlowDefinition>
 
 Parameters:
 
 headers - the Map of headers to enrich.
 
 Returns:
 
 the current IntegrationFlowDefinition.

Class IntegrationFlowDefinition<B extends IntegrationFlowDefinition<B>>

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Field Summary

Fields inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Method Summary

Methods inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Methods inherited from class java.lang.Object

Method Detail

transform

transform

filter

filter

handle

handle

split

route

route

fixedSubscriberChannel

fixedSubscriberChannel

channel

channel

channel

channel

publishSubscribeChannel

publishSubscribeChannel

wireTap

wireTap

wireTap

wireTap

wireTap

wireTap

wireTap

controlBus

controlBus

transform

transform

transform

transform

transform

transform

transform

convert

transform

convert

transform

filter

filter

filter

filter

filter

filter

filter

filter

filter

handle

handle

handle

handle

handle

handle

handle

handle

handle

handle

handle

handle

handle

bridge

bridge

delay

delay

enrich

enrichHeaders

enrichHeaders

enrichHeaders

enrichHeaders

split

split

split