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(ComponentConfigurer<AggregatorSpec> aggregatorConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer) |
B |
aggregate(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer) |
B |
bridge(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.BridgeHandler>> endpointConfigurer) |
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,
EndpointConfigurer<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,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
controlBus() |
B |
controlBus(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
B |
delay(java.lang.String groupId,
java.lang.String expression) |
B |
delay(java.lang.String groupId,
java.lang.String expression,
EndpointConfigurer<DelayerEndpointSpec> endpointConfigurer) |
B |
enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer) |
B |
enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.ContentEnricher>> endpointConfigurer) |
B |
enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer) |
B |
enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer,
EndpointConfigurer<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,
EndpointConfigurer<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,
EndpointConfigurer<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,
EndpointConfigurer<FilterEndpointSpec> endpointConfigurer) |
<P> B |
filter(org.springframework.integration.core.GenericSelector<P> genericSelector,
EndpointConfigurer<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(org.springframework.messaging.MessageChannel requestChannel) |
B |
gateway(org.springframework.messaging.MessageChannel requestChannel,
EndpointConfigurer<GatewayEndpointSpec> endpointConfigurer) |
B |
gateway(java.lang.String requestChannel) |
B |
gateway(java.lang.String requestChannel,
EndpointConfigurer<GatewayEndpointSpec> endpointConfigurer) |
<P> B |
handle(java.lang.Class<P> payloadType,
GenericHandler<P> handler) |
<P> B |
handle(java.lang.Class<P> payloadType,
GenericHandler<P> handler,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
<P> B |
handle(GenericHandler<P> handler) |
<P> B |
handle(GenericHandler<P> handler,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
<H extends org.springframework.messaging.MessageHandler> |
handle(H messageHandler,
EndpointConfigurer<GenericEndpointSpec<H>> endpointConfigurer) |
B |
handle(org.springframework.messaging.MessageHandler messageHandler) |
<S extends MessageHandlerSpec<S,? extends org.springframework.messaging.MessageHandler>> |
handle(S messageHandlerSpec) |
<H extends org.springframework.messaging.MessageHandler,S extends MessageHandlerSpec<S,H>> |
handle(S messageHandlerSpec,
EndpointConfigurer<GenericEndpointSpec<H>> endpointConfigurer) |
B |
handle(java.lang.String beanName,
java.lang.String methodName) |
B |
handle(java.lang.String beanName,
java.lang.String methodName,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer) |
B |
headerFilter(org.springframework.integration.transformer.HeaderFilter headerFilter,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer) |
B |
headerFilter(java.lang.String... headersToRemove)
Provides the
HeaderFilter to the current IntegrationFlowBuilder.StandardIntegrationFlow . |
B |
headerFilter(java.lang.String headersToRemove,
boolean patternMatch)
Provides the
HeaderFilter to the current IntegrationFlowBuilder.StandardIntegrationFlow . |
B |
resequence() |
B |
resequence(ComponentConfigurer<ResequencerSpec> resequencerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer) |
B |
resequence(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer) |
B |
route(org.springframework.integration.router.AbstractMessageRouter router) |
<P,T> B |
route(java.lang.Class<P> payloadType,
GenericRouter<P,T> router) |
<P,T> B |
route(java.lang.Class<P> payloadType,
GenericRouter<P,T> router,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
<P,T> B |
route(java.lang.Class<P> payloadType,
GenericRouter<P,T> router,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer) |
<S,T> B |
route(GenericRouter<S,T> router) |
<S,T> B |
route(GenericRouter<S,T> router,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
<S,T> B |
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,
EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer) |
<R extends org.springframework.integration.router.AbstractMessageRouter> |
route(R router,
EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer) |
B |
route(java.lang.String expression) |
B |
route(java.lang.String expression,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer) |
B |
route(java.lang.String expression,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer,
EndpointConfigurer<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,
ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer) |
B |
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) |
B |
routeToRecipients(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer) |
B |
routeToRecipients(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer,
EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.RecipientListRouter>> endpointConfigurer) |
<P> B |
split(java.lang.Class<P> payloadType,
GenericSplitter<P> splitter) |
<P> B |
split(java.lang.Class<P> payloadType,
GenericSplitter<P> splitter,
EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer) |
B |
split(EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.DefaultMessageSplitter>> endpointConfigurer) |
<T> B |
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) |
B |
split(java.lang.String expression,
EndpointConfigurer<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,
EndpointConfigurer<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,
EndpointConfigurer<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,
EndpointConfigurer<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(org.springframework.messaging.MessageChannel messageChannel)
public B channel(MessageChannelSpec<?,?> messageChannelSpec)
public B controlBus()
public B controlBus(EndpointConfigurer<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, EndpointConfigurer<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, EndpointConfigurer<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, EndpointConfigurer<FilterEndpointSpec> endpointConfigurer)
public <P> B filter(java.lang.Class<P> payloadType, org.springframework.integration.core.GenericSelector<P> genericSelector, EndpointConfigurer<FilterEndpointSpec> endpointConfigurer)
public <S extends MessageHandlerSpec<S,? extends org.springframework.messaging.MessageHandler>> B handle(S 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, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer)
public <P> B handle(GenericHandler<P> handler)
public <P> B handle(GenericHandler<P> handler, EndpointConfigurer<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, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.ServiceActivatingHandler>> endpointConfigurer)
public <H extends org.springframework.messaging.MessageHandler,S extends MessageHandlerSpec<S,H>> B handle(S messageHandlerSpec, EndpointConfigurer<GenericEndpointSpec<H>> endpointConfigurer)
public <H extends org.springframework.messaging.MessageHandler> B handle(H messageHandler, EndpointConfigurer<GenericEndpointSpec<H>> endpointConfigurer)
public B bridge(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.handler.BridgeHandler>> endpointConfigurer)
public B delay(java.lang.String groupId, java.lang.String expression)
public B delay(java.lang.String groupId, java.lang.String expression, EndpointConfigurer<DelayerEndpointSpec> endpointConfigurer)
public B enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer)
public B enrich(ComponentConfigurer<EnricherSpec> enricherConfigurer, EndpointConfigurer<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, EndpointConfigurer<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, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer)
public B enrichHeaders(ComponentConfigurer<HeaderEnricherSpec> headerEnricherConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B split(EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.DefaultMessageSplitter>> endpointConfigurer)
public B split(java.lang.String expression, EndpointConfigurer<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, EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public <P> B split(java.lang.Class<P> payloadType, GenericSplitter<P> splitter)
public <T> B split(GenericSplitter<T> splitter, EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public <P> B split(java.lang.Class<P> payloadType, GenericSplitter<P> splitter, EndpointConfigurer<SplitterEndpointSpec<org.springframework.integration.splitter.MethodInvokingSplitter>> endpointConfigurer)
public <S extends org.springframework.integration.splitter.AbstractMessageSplitter> B split(S splitter, EndpointConfigurer<SplitterEndpointSpec<S>> endpointConfigurer)
public B headerFilter(java.lang.String... headersToRemove)
HeaderFilter
to the current IntegrationFlowBuilder.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 IntegrationFlowBuilder.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, EndpointConfigurer<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, EndpointConfigurer<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, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.transformer.MessageTransformingHandler>> endpointConfigurer)
public B resequence()
public B resequence(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer)
public B resequence(ComponentConfigurer<ResequencerSpec> resequencerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.ResequencingMessageHandler>> endpointConfigurer)
public B aggregate()
public B aggregate(EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.aggregator.AggregatingMessageHandler>> endpointConfigurer)
public B aggregate(ComponentConfigurer<AggregatorSpec> aggregatorConfigurer, EndpointConfigurer<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, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public B 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 B route(java.lang.String expression)
public B route(java.lang.String expression, ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer)
public B route(java.lang.String expression, ComponentConfigurer<RouterSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.ExpressionEvaluatingRouter>> endpointConfigurer)
public <S,T> B route(GenericRouter<S,T> router)
public <S,T> B route(GenericRouter<S,T> router, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public <P,T> B route(java.lang.Class<P> payloadType, GenericRouter<P,T> router)
public <P,T> B route(java.lang.Class<P> payloadType, GenericRouter<P,T> router, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer)
public <S,T> B route(GenericRouter<S,T> router, ComponentConfigurer<RouterSpec<org.springframework.integration.router.MethodInvokingRouter>> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<org.springframework.integration.router.MethodInvokingRouter>> endpointConfigurer)
public <P,T> B route(java.lang.Class<P> payloadType, GenericRouter<P,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> B route(R router, ComponentConfigurer<RouterSpec<R>> routerConfigurer, EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer)
public B routeToRecipients(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer)
public B routeToRecipients(ComponentConfigurer<RecipientListRouterSpec> routerConfigurer, EndpointConfigurer<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, EndpointConfigurer<GenericEndpointSpec<R>> endpointConfigurer)
public B gateway(java.lang.String requestChannel)
public B gateway(java.lang.String requestChannel, EndpointConfigurer<GatewayEndpointSpec> endpointConfigurer)
public B gateway(org.springframework.messaging.MessageChannel requestChannel)
public B gateway(org.springframework.messaging.MessageChannel requestChannel, EndpointConfigurer<GatewayEndpointSpec> endpointConfigurer)
protected final B _this()