public final class IntegrationFlowBuilder
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
IntegrationFlowBuilder |
aggregate() |
IntegrationFlowBuilder |
aggregate(org.springframework.integration.aggregator.AggregatingMessageHandler aggregator) |
IntegrationFlowBuilder |
aggregate(org.springframework.integration.aggregator.AggregatingMessageHandler aggregator,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
aggregate(ComponentConfigurer<AggregatorSpec> aggregatorConfigurer) |
IntegrationFlowBuilder |
aggregate(ComponentConfigurer<AggregatorSpec> aggregatorConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
aggregate(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
bridge(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.BridgeHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
channel(org.springframework.messaging.MessageChannel messageChannel) |
IntegrationFlowBuilder |
channel(MessageChannelSpec<?,?> messageChannelSpec) |
IntegrationFlowBuilder |
channel(java.lang.String messageChannelName) |
IntegrationFlowBuilder |
claimCheckIn(org.springframework.integration.store.MessageStore messageStore) |
IntegrationFlowBuilder |
claimCheckIn(org.springframework.integration.store.MessageStore messageStore,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
claimCheckOut(org.springframework.integration.store.MessageStore messageStore) |
IntegrationFlowBuilder |
claimCheckOut(org.springframework.integration.store.MessageStore messageStore,
boolean removeMessage) |
IntegrationFlowBuilder |
claimCheckOut(org.springframework.integration.store.MessageStore messageStore,
boolean removeMessage,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
controlBus() |
IntegrationFlowBuilder |
delay(java.lang.String groupId,
java.lang.String expression) |
IntegrationFlowBuilder |
delay(java.lang.String groupId,
java.lang.String expression,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.DelayHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer) |
IntegrationFlowBuilder |
enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.ContentEnricher>> endpointConfigurer) |
IntegrationFlowBuilder |
enrich(org.springframework.integration.transformer.ContentEnricher contentEnricher) |
IntegrationFlowBuilder |
enrich(org.springframework.integration.transformer.ContentEnricher contentEnricher,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.ContentEnricher>> endpointConfigurer) |
IntegrationFlowBuilder |
enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer) |
IntegrationFlowBuilder |
enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
enrichHeaders(org.springframework.integration.transformer.HeaderEnricher headerEnricher) |
IntegrationFlowBuilder |
enrichHeaders(org.springframework.integration.transformer.HeaderEnricher headerEnricher,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
<S> IntegrationFlowBuilder |
filter(org.springframework.integration.core.GenericSelector<S> genericSelector) |
<S> IntegrationFlowBuilder |
filter(org.springframework.integration.core.GenericSelector<S> genericSelector,
EndpointConfigurer<FilterEndpointSpec> endpointConfigurer) |
IntegrationFlowBuilder |
filter(java.lang.String expression) |
IntegrationFlowBuilder |
fixedSubscriberChannel() |
IntegrationFlowBuilder |
fixedSubscriberChannel(java.lang.String messageChannelName) |
IntegrationFlow |
get() |
<H extends org.springframework.messaging.MessageHandler> |
handle(H messageHandler,
EndpointConfigurer<GenericEndpointSpec<H>> endpointConfigurer) |
IntegrationFlowBuilder |
handle(org.springframework.messaging.MessageHandler messageHandler) |
IntegrationFlowBuilder |
handle(java.lang.String beanName,
java.lang.String methodName) |
IntegrationFlowBuilder |
handle(java.lang.String beanName,
java.lang.String methodName,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
headerFilter(org.springframework.integration.transformer.HeaderFilter headerFilter,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
headerFilter(java.lang.String... headersToRemove)
Provides the
HeaderFilter to the current IntegrationFlow . |
IntegrationFlowBuilder |
headerFilter(java.lang.String headersToRemove,
boolean patternMatch)
Provides the
HeaderFilter to the current IntegrationFlow . |
IntegrationFlowBuilder |
recipientListRoute(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer) |
IntegrationFlowBuilder |
recipientListRoute(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.RecipientListRouter>> endpointConfigurer) |
IntegrationFlowBuilder |
resequence() |
IntegrationFlowBuilder |
resequence(ComponentConfigurer<ResequencerSpec> resequencerConfigurer) |
IntegrationFlowBuilder |
resequence(ComponentConfigurer<ResequencerSpec> resequencerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
resequence(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
resequence(org.springframework.integration.aggregator.ResequencingMessageHandler resequencer) |
IntegrationFlowBuilder |
resequence(org.springframework.integration.aggregator.ResequencingMessageHandler resequencer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
route(org.springframework.integration.router.AbstractMessageRouter router) |
<S,T> IntegrationFlowBuilder |
route(GenericRouter<S,T> router) |
<S,T> IntegrationFlowBuilder |
route(GenericRouter<S,T> router,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
<S,T> IntegrationFlowBuilder |
route(GenericRouter<S,T> router,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer) |
<R extends org.springframework.integration.router.AbstractMappingMessageRouter> |
route(R router,
ComponentConfigurer<RouterSpec<R>> routerConfigurer) |
<R extends org.springframework.integration.router.AbstractMappingMessageRouter> |
route(R router,
ComponentConfigurer<RouterSpec<R>> routerConfigurer,
EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer) |
<R extends org.springframework.integration.router.AbstractMessageRouter> |
route(R router,
EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer) |
IntegrationFlowBuilder |
route(java.lang.String expression) |
IntegrationFlowBuilder |
route(java.lang.String expression,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer) |
IntegrationFlowBuilder |
route(java.lang.String expression,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> endpointConfigurer) |
IntegrationFlowBuilder |
route(java.lang.String beanName,
java.lang.String method) |
IntegrationFlowBuilder |
route(java.lang.String beanName,
java.lang.String method,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
IntegrationFlowBuilder |
route(java.lang.String beanName,
java.lang.String method,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer) |
IntegrationFlowBuilder |
split() |
IntegrationFlowBuilder |
split(org.springframework.integration.splitter.AbstractMessageSplitter splitter) |
IntegrationFlowBuilder |
split(EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.DefaultMessageSplitter>> endpointConfigurer) |
<T> IntegrationFlowBuilder |
split(GenericSplitter<T> splitter) |
<T> IntegrationFlowBuilder |
split(GenericSplitter<T> splitter,
EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer) |
<S extends org.springframework.integration.splitter.AbstractMessageSplitter> |
split(S splitter,
EndpointConfigurer<SplitterEndpointSpec<S>> endpointConfigurer) |
IntegrationFlowBuilder |
split(java.lang.String expression) |
IntegrationFlowBuilder |
split(java.lang.String expression,
EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.ExpressionEvaluatingSplitter>> endpointConfigurer) |
IntegrationFlowBuilder |
split(java.lang.String beanName,
java.lang.String methodName) |
IntegrationFlowBuilder |
split(java.lang.String beanName,
java.lang.String methodName,
EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer) |
<S,T> IntegrationFlowBuilder |
transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer) |
<S,T> IntegrationFlowBuilder |
transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
IntegrationFlowBuilder |
transform(java.lang.String expression) |
public IntegrationFlowBuilder fixedSubscriberChannel()
public IntegrationFlowBuilder fixedSubscriberChannel(java.lang.String messageChannelName)
public IntegrationFlowBuilder channel(java.lang.String messageChannelName)
public IntegrationFlowBuilder channel(org.springframework.messaging.MessageChannel messageChannel)
public IntegrationFlowBuilder channel(MessageChannelSpec<?,?> messageChannelSpec)
public IntegrationFlowBuilder controlBus()
public IntegrationFlowBuilder transform(java.lang.String expression)
public <S,T> IntegrationFlowBuilder transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer)
public <S,T> IntegrationFlowBuilder transform(org.springframework.integration.transformer.GenericTransformer<S,T> genericTransformer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public IntegrationFlowBuilder filter(java.lang.String expression)
public <S> IntegrationFlowBuilder filter(org.springframework.integration.core.GenericSelector<S> genericSelector)
public <S> IntegrationFlowBuilder filter(org.springframework.integration.core.GenericSelector<S> genericSelector, EndpointConfigurer<FilterEndpointSpec> endpointConfigurer)
public IntegrationFlowBuilder handle(org.springframework.messaging.MessageHandler messageHandler)
public IntegrationFlowBuilder handle(java.lang.String beanName, java.lang.String methodName)
public IntegrationFlowBuilder handle(java.lang.String beanName, java.lang.String methodName, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer)
public <H extends org.springframework.messaging.MessageHandler> IntegrationFlowBuilder handle(H messageHandler, EndpointConfigurer<GenericEndpointSpec<H>> endpointConfigurer)
public IntegrationFlowBuilder bridge(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.BridgeHandler>> endpointConfigurer)
public IntegrationFlowBuilder delay(java.lang.String groupId, java.lang.String expression)
public IntegrationFlowBuilder delay(java.lang.String groupId, java.lang.String expression, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.DelayHandler>> endpointConfigurer)
public IntegrationFlowBuilder enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer)
public IntegrationFlowBuilder enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.ContentEnricher>> endpointConfigurer)
public IntegrationFlowBuilder enrich(org.springframework.integration.transformer.ContentEnricher contentEnricher)
public IntegrationFlowBuilder enrich(org.springframework.integration.transformer.ContentEnricher contentEnricher, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.ContentEnricher>> endpointConfigurer)
public IntegrationFlowBuilder enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer)
public IntegrationFlowBuilder enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public IntegrationFlowBuilder enrichHeaders(org.springframework.integration.transformer.HeaderEnricher headerEnricher)
public IntegrationFlowBuilder enrichHeaders(org.springframework.integration.transformer.HeaderEnricher headerEnricher, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public IntegrationFlowBuilder split()
public IntegrationFlowBuilder split(EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.DefaultMessageSplitter>> endpointConfigurer)
public IntegrationFlowBuilder split(java.lang.String expression)
public IntegrationFlowBuilder split(java.lang.String expression, EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.ExpressionEvaluatingSplitter>> endpointConfigurer)
public IntegrationFlowBuilder split(java.lang.String beanName, java.lang.String methodName)
public IntegrationFlowBuilder split(java.lang.String beanName, java.lang.String methodName, EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public IntegrationFlowBuilder split(org.springframework.integration.splitter.AbstractMessageSplitter splitter)
public <T> IntegrationFlowBuilder split(GenericSplitter<T> splitter)
public <T> IntegrationFlowBuilder split(GenericSplitter<T> splitter, EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public <S extends org.springframework.integration.splitter.AbstractMessageSplitter> IntegrationFlowBuilder split(S splitter, EndpointConfigurer<SplitterEndpointSpec<S>> endpointConfigurer)
public IntegrationFlowBuilder headerFilter(java.lang.String... headersToRemove)
HeaderFilter
to the current IntegrationFlow
.headersToRemove
- the array of headers (or patterns) to remove from MessageHeaders
.IntegrationFlowBuilder
.public IntegrationFlowBuilder headerFilter(java.lang.String headersToRemove, boolean patternMatch)
HeaderFilter
to the current IntegrationFlow
.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.IntegrationFlowBuilder
.public IntegrationFlowBuilder headerFilter(org.springframework.integration.transformer.HeaderFilter headerFilter, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public IntegrationFlowBuilder claimCheckIn(org.springframework.integration.store.MessageStore messageStore)
public IntegrationFlowBuilder claimCheckIn(org.springframework.integration.store.MessageStore messageStore, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public IntegrationFlowBuilder claimCheckOut(org.springframework.integration.store.MessageStore messageStore)
public IntegrationFlowBuilder claimCheckOut(org.springframework.integration.store.MessageStore messageStore, boolean removeMessage)
public IntegrationFlowBuilder claimCheckOut(org.springframework.integration.store.MessageStore messageStore, boolean removeMessage, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public IntegrationFlowBuilder resequence()
public IntegrationFlowBuilder resequence(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer)
public IntegrationFlowBuilder resequence(ComponentConfigurer<ResequencerSpec> resequencerConfigurer)
public IntegrationFlowBuilder resequence(ComponentConfigurer<ResequencerSpec> resequencerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer)
public IntegrationFlowBuilder resequence(org.springframework.integration.aggregator.ResequencingMessageHandler resequencer)
public IntegrationFlowBuilder resequence(org.springframework.integration.aggregator.ResequencingMessageHandler resequencer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer)
public IntegrationFlowBuilder aggregate()
public IntegrationFlowBuilder aggregate(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer)
public IntegrationFlowBuilder aggregate(ComponentConfigurer<AggregatorSpec> aggregatorConfigurer)
public IntegrationFlowBuilder aggregate(ComponentConfigurer<AggregatorSpec> aggregatorConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer)
public IntegrationFlowBuilder aggregate(org.springframework.integration.aggregator.AggregatingMessageHandler aggregator)
public IntegrationFlowBuilder aggregate(org.springframework.integration.aggregator.AggregatingMessageHandler aggregator, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer)
public IntegrationFlowBuilder route(java.lang.String beanName, java.lang.String method)
public IntegrationFlowBuilder route(java.lang.String beanName, java.lang.String method, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public IntegrationFlowBuilder route(java.lang.String beanName, java.lang.String method, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer)
public IntegrationFlowBuilder route(java.lang.String expression)
public IntegrationFlowBuilder route(java.lang.String expression, ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer)
public IntegrationFlowBuilder route(java.lang.String expression, ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> endpointConfigurer)
public <S,T> IntegrationFlowBuilder route(GenericRouter<S,T> router)
public <S,T> IntegrationFlowBuilder route(GenericRouter<S,T> router, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public <S,T> IntegrationFlowBuilder route(GenericRouter<S,T> router, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer)
public <R extends org.springframework.integration.router.AbstractMappingMessageRouter> IntegrationFlowBuilder route(R router, ComponentConfigurer<RouterSpec<R>> routerConfigurer)
public <R extends org.springframework.integration.router.AbstractMappingMessageRouter> IntegrationFlowBuilder route(R router, ComponentConfigurer<RouterSpec<R>> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer)
public IntegrationFlowBuilder recipientListRoute(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer)
public IntegrationFlowBuilder recipientListRoute(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.RecipientListRouter>> endpointConfigurer)
public IntegrationFlowBuilder route(org.springframework.integration.router.AbstractMessageRouter router)
public <R extends org.springframework.integration.router.AbstractMessageRouter> IntegrationFlowBuilder route(R router, EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer)
public IntegrationFlow get()