public abstract class IntegrationFlowDefinition<B extends IntegrationFlowDefinition<B>>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
currentComponent |
protected org.springframework.messaging.MessageChannel |
currentMessageChannel |
protected java.util.Set<java.lang.Object> |
integrationComponents |
Modifier and Type | Method and Description |
---|---|
protected B |
_this() |
B |
aggregate() |
B |
aggregate(Consumer<AggregatorSpec> aggregatorConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer) |
B |
aggregate(Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer) |
B |
bridge(Consumer<GenericEndpointSpec<org.springframework.integration.handler.BridgeHandler>> endpointConfigurer) |
B |
channel(Function<Channels,MessageChannelSpec<?,?>> channels) |
B |
channel(org.springframework.messaging.MessageChannel messageChannel) |
B |
channel(MessageChannelSpec<?,?> messageChannelSpec) |
B |
channel(java.lang.String messageChannelName) |
B |
claimCheckIn(org.springframework.integration.store.MessageStore messageStore) |
B |
claimCheckIn(org.springframework.integration.store.MessageStore messageStore,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
claimCheckOut(org.springframework.integration.store.MessageStore messageStore) |
B |
claimCheckOut(org.springframework.integration.store.MessageStore messageStore,
boolean removeMessage) |
B |
claimCheckOut(org.springframework.integration.store.MessageStore messageStore,
boolean removeMessage,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
controlBus() |
B |
controlBus(Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
B |
delay(java.lang.String groupId) |
B |
delay(java.lang.String groupId,
Consumer<DelayerEndpointSpec> endpointConfigurer) |
<P> B |
delay(java.lang.String groupId,
Function<org.springframework.messaging.Message<P>,java.lang.Object> function) |
<P> B |
delay(java.lang.String groupId,
Function<org.springframework.messaging.Message<P>,java.lang.Object> function,
Consumer<DelayerEndpointSpec> endpointConfigurer) |
B |
delay(java.lang.String groupId,
java.lang.String expression) |
B |
delay(java.lang.String groupId,
java.lang.String expression,
Consumer<DelayerEndpointSpec> endpointConfigurer) |
B |
enrich(Consumer<EnricherSpec> enricherConfigurer) |
B |
enrich(Consumer<EnricherSpec> enricherConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.ContentEnricher>> endpointConfigurer) |
B |
enrichHeaders(Consumer<HeaderEnricherSpec> headerEnricherConfigurer) |
B |
enrichHeaders(Consumer<HeaderEnricherSpec> headerEnricherConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
enrichHeaders(java.util.Map<java.lang.String,java.lang.Object> headers)
Accept a
Map of values to be used for the
Message header enrichment. |
B |
enrichHeaders(java.util.Map<java.lang.String,java.lang.Object> headers,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
enrichHeaders(MapBuilder<?,java.lang.String,java.lang.Object> headers) |
B |
enrichHeaders(MapBuilder<?,java.lang.String,java.lang.Object> headers,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
<P> B |
filter(java.lang.Class<P> payloadType,
org.springframework.integration.core.GenericSelector<P> genericSelector) |
<P> B |
filter(java.lang.Class<P> payloadType,
org.springframework.integration.core.GenericSelector<P> genericSelector,
Consumer<FilterEndpointSpec> endpointConfigurer) |
<P> B |
filter(org.springframework.integration.core.GenericSelector<P> genericSelector,
Consumer<FilterEndpointSpec> endpointConfigurer) |
<S> B |
filter(org.springframework.integration.core.GenericSelector<S> genericSelector) |
B |
filter(java.lang.String expression) |
B |
fixedSubscriberChannel() |
B |
fixedSubscriberChannel(java.lang.String messageChannelName) |
B |
gateway(IntegrationFlow flow) |
B |
gateway(IntegrationFlow flow,
Consumer<GatewayEndpointSpec> endpointConfigurer) |
B |
gateway(org.springframework.messaging.MessageChannel requestChannel) |
B |
gateway(org.springframework.messaging.MessageChannel requestChannel,
Consumer<GatewayEndpointSpec> endpointConfigurer) |
B |
gateway(java.lang.String requestChannel) |
B |
gateway(java.lang.String requestChannel,
Consumer<GatewayEndpointSpec> endpointConfigurer) |
protected StandardIntegrationFlow |
get() |
<P> B |
handle(java.lang.Class<P> payloadType,
GenericHandler<P> handler) |
<P> B |
handle(java.lang.Class<P> payloadType,
GenericHandler<P> handler,
Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
<P> B |
handle(GenericHandler<P> handler) |
<P> B |
handle(GenericHandler<P> handler,
Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
<H extends org.springframework.messaging.MessageHandler> |
handle(H messageHandler,
Consumer<GenericEndpointSpec<H>> endpointConfigurer) |
B |
handle(org.springframework.messaging.MessageHandler messageHandler) |
B |
handle(MessageHandlerSpec<?,? extends org.springframework.messaging.MessageHandler> messageHandlerSpec) |
<H extends org.springframework.messaging.MessageHandler> |
handle(MessageHandlerSpec<?,H> messageHandlerSpec,
Consumer<GenericEndpointSpec<H>> endpointConfigurer) |
B |
handle(java.lang.String beanName,
java.lang.String methodName) |
B |
handle(java.lang.String beanName,
java.lang.String methodName,
Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
<H extends org.springframework.messaging.MessageHandler> |
handleWithAdapter(Function<Adapters,MessageHandlerSpec<?,H>> adapters) |
<H extends org.springframework.messaging.MessageHandler> |
handleWithAdapter(Function<Adapters,MessageHandlerSpec<?,H>> adapters,
Consumer<GenericEndpointSpec<H>> endpointConfigurer) |
B |
headerFilter(org.springframework.integration.transformer.HeaderFilter headerFilter,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
headerFilter(java.lang.String... headersToRemove)
Provides the
HeaderFilter to the current StandardIntegrationFlow . |
B |
headerFilter(java.lang.String headersToRemove,
boolean patternMatch)
Provides the
HeaderFilter to the current StandardIntegrationFlow . |
B |
publishSubscribeChannel(Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer) |
B |
publishSubscribeChannel(java.util.concurrent.Executor executor,
Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer) |
B |
resequence() |
B |
resequence(Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer) |
B |
resequence(Consumer<ResequencerSpec> resequencerConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer) |
B |
route(org.springframework.integration.router.AbstractMessageRouter router) |
<P,T> B |
route(java.lang.Class<P> payloadType,
Function<P,T> router) |
<P,T> B |
route(java.lang.Class<P> payloadType,
Function<P,T> router,
Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
<P,T> B |
route(java.lang.Class<P> payloadType,
Function<P,T> router,
Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer) |
<S,T> B |
route(Function<S,T> router) |
<S,T> B |
route(Function<S,T> router,
Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
<S,T> B |
route(Function<S,T> router,
Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer) |
<R extends org.springframework.integration.router.AbstractMessageRouter> |
route(R router,
Consumer<GenericEndpointSpec<R>> endpointConfigurer) |
<R extends org.springframework.integration.router.AbstractMappingMessageRouter> |
route(R router,
Consumer<RouterSpec<R>> routerConfigurer,
Consumer<GenericEndpointSpec<R>> endpointConfigurer) |
B |
route(java.lang.String expression) |
B |
route(java.lang.String expression,
Consumer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer) |
B |
route(java.lang.String expression,
Consumer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> endpointConfigurer) |
B |
route(java.lang.String beanName,
java.lang.String method) |
B |
route(java.lang.String beanName,
java.lang.String method,
Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
B |
route(java.lang.String beanName,
java.lang.String method,
Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer) |
B |
routeToRecipients(Consumer<RecipientListRouterSpec> routerConfigurer) |
B |
routeToRecipients(Consumer<RecipientListRouterSpec> routerConfigurer,
Consumer<GenericEndpointSpec<org.springframework.integration.router.RecipientListRouter>> endpointConfigurer) |
B |
split() |
<P> B |
split(java.lang.Class<P> payloadType,
Function<P,?> splitter) |
<P> B |
split(java.lang.Class<P> payloadType,
Function<P,?> splitter,
Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer) |
B |
split(Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.DefaultMessageSplitter>> endpointConfigurer) |
<P> B |
split(Function<P,?> splitter,
Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer) |
<S extends org.springframework.integration.splitter.AbstractMessageSplitter> |
split(S splitter,
Consumer<SplitterEndpointSpec<S>> endpointConfigurer) |
B |
split(java.lang.String expression,
Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.ExpressionEvaluatingSplitter>> endpointConfigurer) |
B |
split(java.lang.String beanName,
java.lang.String methodName) |
B |
split(java.lang.String beanName,
java.lang.String methodName,
Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer) |
<P,T> B |
transform(java.lang.Class<P> payloadType,
org.springframework.integration.transformer.GenericTransformer<P,T> genericTransformer) |
<P,T> B |
transform(java.lang.Class<P> payloadType,
org.springframework.integration.transformer.GenericTransformer<P,T> genericTransformer,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
<S,T> B |
transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer) |
<S,T> B |
transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer,
Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
transform(java.lang.String expression) |
protected final java.util.Set<java.lang.Object> integrationComponents
protected org.springframework.messaging.MessageChannel currentMessageChannel
protected java.lang.Object currentComponent
public B fixedSubscriberChannel()
public B fixedSubscriberChannel(java.lang.String messageChannelName)
public B channel(java.lang.String messageChannelName)
public B channel(Function<Channels,MessageChannelSpec<?,?>> channels)
public B channel(MessageChannelSpec<?,?> messageChannelSpec)
public B channel(org.springframework.messaging.MessageChannel messageChannel)
public B publishSubscribeChannel(Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
public B publishSubscribeChannel(java.util.concurrent.Executor executor, Consumer<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
public B controlBus()
public B controlBus(Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer)
public B transform(java.lang.String expression)
public <S,T> B transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer)
public <P,T> B transform(java.lang.Class<P> payloadType, org.springframework.integration.transformer.GenericTransformer<P,T> genericTransformer)
public <S,T> B transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public <P,T> B transform(java.lang.Class<P> payloadType, org.springframework.integration.transformer.GenericTransformer<P,T> genericTransformer, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B filter(java.lang.String expression)
public <S> B filter(org.springframework.integration.core.GenericSelector<S> genericSelector)
public <P> B filter(java.lang.Class<P> payloadType, org.springframework.integration.core.GenericSelector<P> genericSelector)
public <P> B filter(org.springframework.integration.core.GenericSelector<P> genericSelector, Consumer<FilterEndpointSpec> endpointConfigurer)
public <P> B filter(java.lang.Class<P> payloadType, org.springframework.integration.core.GenericSelector<P> genericSelector, Consumer<FilterEndpointSpec> endpointConfigurer)
public <H extends org.springframework.messaging.MessageHandler> B handleWithAdapter(Function<Adapters,MessageHandlerSpec<?,H>> adapters)
public <H extends org.springframework.messaging.MessageHandler> B handleWithAdapter(Function<Adapters,MessageHandlerSpec<?,H>> adapters, Consumer<GenericEndpointSpec<H>> endpointConfigurer)
public B handle(MessageHandlerSpec<?,? extends org.springframework.messaging.MessageHandler> messageHandlerSpec)
public B handle(org.springframework.messaging.MessageHandler messageHandler)
public B handle(java.lang.String beanName, java.lang.String methodName)
public B handle(java.lang.String beanName, java.lang.String methodName, Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer)
public <P> B handle(GenericHandler<P> handler)
public <P> B handle(GenericHandler<P> handler, Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer)
public <P> B handle(java.lang.Class<P> payloadType, GenericHandler<P> handler)
public <P> B handle(java.lang.Class<P> payloadType, GenericHandler<P> handler, Consumer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer)
public <H extends org.springframework.messaging.MessageHandler> B handle(MessageHandlerSpec<?,H> messageHandlerSpec, Consumer<GenericEndpointSpec<H>> endpointConfigurer)
public <H extends org.springframework.messaging.MessageHandler> B handle(H messageHandler, Consumer<GenericEndpointSpec<H>> endpointConfigurer)
public B bridge(Consumer<GenericEndpointSpec<org.springframework.integration.handler.BridgeHandler>> endpointConfigurer)
public B delay(java.lang.String groupId)
public B delay(java.lang.String groupId, Consumer<DelayerEndpointSpec> endpointConfigurer)
public B delay(java.lang.String groupId, java.lang.String expression)
public <P> B delay(java.lang.String groupId, Function<org.springframework.messaging.Message<P>,java.lang.Object> function)
public <P> B delay(java.lang.String groupId, Function<org.springframework.messaging.Message<P>,java.lang.Object> function, Consumer<DelayerEndpointSpec> endpointConfigurer)
public B delay(java.lang.String groupId, java.lang.String expression, Consumer<DelayerEndpointSpec> endpointConfigurer)
public B enrich(Consumer<EnricherSpec> enricherConfigurer)
public B enrich(Consumer<EnricherSpec> enricherConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.ContentEnricher>> endpointConfigurer)
public B enrichHeaders(MapBuilder<?,java.lang.String,java.lang.Object> headers)
public B enrichHeaders(MapBuilder<?,java.lang.String,java.lang.Object> headers, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B enrichHeaders(java.util.Map<java.lang.String,java.lang.Object> headers)
Map
of values to be used for the
Message
header enrichment.
values
can apply an Expression
to be evaluated against a request Message
.headers
- the Map of headers to enrich.public B enrichHeaders(java.util.Map<java.lang.String,java.lang.Object> headers, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B enrichHeaders(Consumer<HeaderEnricherSpec> headerEnricherConfigurer)
public B enrichHeaders(Consumer<HeaderEnricherSpec> headerEnricherConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B split()
public B split(Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.DefaultMessageSplitter>> endpointConfigurer)
public B split(java.lang.String expression, Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.ExpressionEvaluatingSplitter>> endpointConfigurer)
public B split(java.lang.String beanName, java.lang.String methodName)
public B split(java.lang.String beanName, java.lang.String methodName, Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public <P> B split(Function<P,?> splitter, Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public <P> B split(java.lang.Class<P> payloadType, Function<P,?> splitter, Consumer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public <S extends org.springframework.integration.splitter.AbstractMessageSplitter> B split(S splitter, Consumer<SplitterEndpointSpec<S>> endpointConfigurer)
public B headerFilter(java.lang.String... headersToRemove)
HeaderFilter
to the current StandardIntegrationFlow
.headersToRemove
- the array of headers (or patterns)
to remove from MessageHeaders
.IntegrationFlowDefinition
.public B headerFilter(java.lang.String headersToRemove, boolean patternMatch)
HeaderFilter
to the current StandardIntegrationFlow
.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.IntegrationFlowDefinition
.public B headerFilter(org.springframework.integration.transformer.HeaderFilter headerFilter, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B claimCheckIn(org.springframework.integration.store.MessageStore messageStore)
public B claimCheckIn(org.springframework.integration.store.MessageStore messageStore, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B claimCheckOut(org.springframework.integration.store.MessageStore messageStore)
public B claimCheckOut(org.springframework.integration.store.MessageStore messageStore, boolean removeMessage)
public B claimCheckOut(org.springframework.integration.store.MessageStore messageStore, boolean removeMessage, Consumer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B resequence()
public B resequence(Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer)
public B resequence(Consumer<ResequencerSpec> resequencerConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer)
public B aggregate()
public B aggregate(Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer)
public B aggregate(Consumer<AggregatorSpec> aggregatorConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer)
public B route(java.lang.String beanName, java.lang.String method)
public B route(java.lang.String beanName, java.lang.String method, Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public B route(java.lang.String beanName, java.lang.String method, Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer)
public B route(java.lang.String expression)
public B route(java.lang.String expression, Consumer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer)
public B route(java.lang.String expression, Consumer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> endpointConfigurer)
public <S,T> B route(Function<S,T> router, Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public <P,T> B route(java.lang.Class<P> payloadType, Function<P,T> router, Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public <S,T> B route(Function<S,T> router, Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer)
public <P,T> B route(java.lang.Class<P> payloadType, Function<P,T> router, Consumer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer)
public <R extends org.springframework.integration.router.AbstractMappingMessageRouter> B route(R router, Consumer<RouterSpec<R>> routerConfigurer, Consumer<GenericEndpointSpec<R>> endpointConfigurer)
public B routeToRecipients(Consumer<RecipientListRouterSpec> routerConfigurer)
public B routeToRecipients(Consumer<RecipientListRouterSpec> routerConfigurer, Consumer<GenericEndpointSpec<org.springframework.integration.router.RecipientListRouter>> endpointConfigurer)
public B route(org.springframework.integration.router.AbstractMessageRouter router)
public <R extends org.springframework.integration.router.AbstractMessageRouter> B route(R router, Consumer<GenericEndpointSpec<R>> endpointConfigurer)
public B gateway(java.lang.String requestChannel)
public B gateway(java.lang.String requestChannel, Consumer<GatewayEndpointSpec> endpointConfigurer)
public B gateway(org.springframework.messaging.MessageChannel requestChannel)
public B gateway(org.springframework.messaging.MessageChannel requestChannel, Consumer<GatewayEndpointSpec> endpointConfigurer)
public B gateway(IntegrationFlow flow)
public B gateway(IntegrationFlow flow, Consumer<GatewayEndpointSpec> endpointConfigurer)
protected final B _this()
protected StandardIntegrationFlow get()