@CompileStatic class GroovyIntegrationFlowDefinition extends Object
The Groovy-specific IntegrationFlowDefinition wrapper.
| Constructor and description |
|---|
protected GroovyIntegrationFlowDefinition
(IntegrationFlowDefinition delegate) |
| Type Params | Return Type | Name and description |
|---|---|---|
|
GroovyIntegrationFlowDefinition |
aggregate(Object aggregatorProcessor)A short-cut for the aggregate((aggregator) -> aggregator.processor(aggregatorProcessor)). |
|
GroovyIntegrationFlowDefinition |
aggregate(Closure<?> aggregator)Populate the AggregatingMessageHandler with provided options from AggregatorSpec. |
|
GroovyIntegrationFlowDefinition |
barrier(long timeout, Closure<?> barrierConfigurer)Populate a BarrierMessageHandler instance for provided timeout and options from BarrierSpec and endpoint options from GenericEndpointSpec. |
|
GroovyIntegrationFlowDefinition |
bridge(Closure<?> endpointConfigurer)Populate a BridgeHandler to the current integration flow position. |
|
GroovyIntegrationFlowDefinition |
channel(String messageChannelName)Populate a MessageChannelReference instance at the current IntegrationFlow chain position. |
|
GroovyIntegrationFlowDefinition |
channel(MessageChannelSpec messageChannelSpec)Populate a MessageChannel instance at the current IntegrationFlow chain position using the MessageChannelSpec fluent API. |
|
GroovyIntegrationFlowDefinition |
channel(MessageChannel messageChannel)Populate the provided MessageChannel instance at the current IntegrationFlow chain position. |
|
GroovyIntegrationFlowDefinition |
channel(Closure<MessageChannelSpec> channels)Populate a MessageChannel instance at the current IntegrationFlow chain position using the Channels factory fluent API. |
|
GroovyIntegrationFlowDefinition |
claimCheckIn(MessageStore messageStore, Closure<?> endpointConfigurer)Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore. |
|
GroovyIntegrationFlowDefinition |
claimCheckOut(MessageStore messageStore, boolean removeMessage, Closure<?> endpointConfigurer)Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore and removeMessage flag.
|
|
GroovyIntegrationFlowDefinition |
controlBus(Closure<?> endpointConfigurer)Populate the Control Bus EI Pattern specific MessageHandler implementation
at the current IntegrationFlow chain position. |
<P> |
GroovyIntegrationFlowDefinition |
convert(Class<P> payloadType, Closure<?> endpointConfigurer)Populate the MessageTransformingHandler instance for the provided payloadType to convert at runtime.
|
<T> |
protected static Consumer<T> |
createConfigurerIfAny(Closure<?> closure) |
|
GroovyIntegrationFlowDefinition |
delay(String groupId, Closure<?> endpointConfigurer)Populate a DelayHandler to the current integration flow position. |
|
GroovyIntegrationFlowDefinition |
enrich(Closure<?> enricherConfigurer)Populate a ContentEnricher to the current integration flow position with provided options. |
|
GroovyIntegrationFlowDefinition |
enrichHeaders(Closure<?> enricherConfigurer)Populate a MessageTransformingHandler for a HeaderEnricher as the result of provided Consumer. |
|
GroovyIntegrationFlowDefinition |
filter(String expression, Closure<?> endpointConfigurer)Populate a MessageFilter with MessageSelector for the provided SpEL expression. |
|
GroovyIntegrationFlowDefinition |
filter(Object service, String methodName, Closure<?> endpointConfigurer)Populate a MessageFilter with MethodInvokingSelector for the method of the provided service. |
|
GroovyIntegrationFlowDefinition |
filter(MessageProcessorSpec<?> messageProcessorSpec, Closure<?> endpointConfigurer)Populate a MessageFilter with MethodInvokingSelector for the MessageProcessor from the provided MessageProcessorSpec. |
<P> |
GroovyIntegrationFlowDefinition |
filter(Class<P> expectedType, Closure<Boolean> genericSelector, Closure<?> endpointConfigurer)Populate a MessageFilter with MethodInvokingSelector for the provided GenericSelector. |
|
GroovyIntegrationFlowDefinition |
fixedSubscriberChannel(String messageChannelName)Populate an FixedSubscriberChannel instance at the current IntegrationFlow chain position. |
<I, O> |
GroovyIntegrationFlowDefinition |
fluxTransform(Function<? super Flux<Message<I>>, ? extends 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)#transform(Function) and emit the result to one more FluxMessageChannel, subscribed in the downstream flow. |
|
GroovyIntegrationFlowDefinition |
gateway(String requestChannel, Closure<?> endpointConfigurer)Populate the "artificial" GatewayMessageHandler for the provided requestChannel to send a request with options from
GatewayEndpointSpec. |
|
GroovyIntegrationFlowDefinition |
gateway(MessageChannel requestChannel, Closure<?> endpointConfigurer)Populate the "artificial" GatewayMessageHandler for the provided requestChannel to send a request with options from
GatewayEndpointSpec. |
|
GroovyIntegrationFlowDefinition |
gateway(IntegrationFlow flow, Closure<?> endpointConfigurer)Populate the "artificial" GatewayMessageHandler for the provided subflow with options from GatewayEndpointSpec.
|
|
GroovyIntegrationFlowDefinition |
handle(String beanName, String methodName, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the method for provided bean at runtime.
|
|
GroovyIntegrationFlowDefinition |
handle(Object service, String methodName, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the method for provided bean at runtime.
|
<P> |
GroovyIntegrationFlowDefinition |
handle(Class<P> expectedType, GenericHandler<P> handler, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the provided GenericHandler at runtime. |
|
GroovyIntegrationFlowDefinition |
handle(MessageProcessorSpec<?> messageProcessorSpec, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler for the MessageProcessor from the provided MessageProcessorSpec. |
<H extends MessageHandler> |
GroovyIntegrationFlowDefinition |
handle(MessageHandlerSpec<?, H> messageHandlerSpec, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler for the selected protocol specific MessageHandler implementation from Namespace Factory:
In addition accept options for the integration endpoint using GenericEndpointSpec. |
<H extends MessageHandler> |
GroovyIntegrationFlowDefinition |
handle(H messageHandler, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler for the provided MessageHandler implementation. |
|
GroovyIntegrationFlowDefinition |
headerFilter(String headersToRemove, boolean patternMatch, Closure<?> endpointConfigurer)Populate the provided MessageTransformingHandler for the provided HeaderFilter. |
|
GroovyIntegrationFlowDefinition |
intercept(ChannelInterceptor[] interceptorArray)Add one or more ChannelInterceptor implementations to the current MessageChannel, in the given order, after any interceptors already registered. |
|
GroovyIntegrationFlowDefinition |
log(LoggingHandler.Level level, String category, String logExpression)Populate a WireTap for the current message channel with the LoggingHandler subscriber for provided LoggingHandler.Level logging level and org.springframework.integration.handler.LoggingHandler
as a default logging category. |
<P> |
GroovyIntegrationFlowDefinition |
log(LoggingHandler.Level level, String category, Function<Message<P>, Object> function)Populate a WireTap for the current message channel with the LoggingHandler subscriber for the provided LoggingHandler.Level logging level, logging category and Function for the log message. |
|
GroovyIntegrationFlowDefinition |
publishSubscribeChannel(Executor executor, Closure<?> publishSubscribeChannelConfigurer)The PublishSubscribeChannel channel method specific implementation to allow the use of the 'subflow' subscriber capability. |
|
GroovyIntegrationFlowDefinition |
publishSubscribeChannel(BroadcastCapableChannel broadcastCapableChannel, Closure<?> publishSubscribeChannelConfigurer)The BroadcastCapableChannel channel method specific implementation to allow the use of the 'subflow' subscriber capability. |
|
GroovyIntegrationFlowDefinition |
resequence(Closure<?> resequencer)Populate the ResequencingMessageHandler with provided options from ResequencerSpec. |
|
GroovyIntegrationFlowDefinition |
route(String beanName, String method, Closure<?> routerConfigurer)Populate the MethodInvokingRouter for provided bean and its method with provided options from RouterSpec. |
|
GroovyIntegrationFlowDefinition |
route(Object service, String methodName, Closure<?> routerConfigurer)Populate the MethodInvokingRouter for the method of the provided service and its method with provided options from RouterSpec. |
<T> |
GroovyIntegrationFlowDefinition |
route(String expression, Closure<?> routerConfigurer)Populate the ExpressionEvaluatingRouter for provided SpEL expression with provided options from RouterSpec. |
<P, T> |
GroovyIntegrationFlowDefinition |
route(Class<P> expectedType, Function<P, T> router, Closure<?> routerConfigurer)Populate the MethodInvokingRouter for provided Function and payload type and options from RouterSpec. |
|
GroovyIntegrationFlowDefinition |
route(MessageProcessorSpec<?> messageProcessorSpec, Closure<?> routerConfigurer)Populate the MethodInvokingRouter for the MessageProcessor from the provided MessageProcessorSpec with default options. |
<R extends AbstractMessageRouter> |
GroovyIntegrationFlowDefinition |
route(R router, Closure<?> endpointConfigurer)Populate the provided AbstractMessageRouter implementation to the current integration flow position. |
|
GroovyIntegrationFlowDefinition |
routeByException(Closure<?> routerConfigurer)Populate the ErrorMessageExceptionTypeRouter with options from the RouterSpec. |
|
GroovyIntegrationFlowDefinition |
routeToRecipients(Closure<?> routerConfigurer)Populate the RecipientListRouter with options from the RecipientListRouterSpec. |
|
GroovyIntegrationFlowDefinition |
scatterGather(MessageChannel scatterChannel, Closure<?> gatherer, Closure<?> scatterGather)Populate a ScatterGatherHandler to the current integration flow position based on the provided MessageChannel for scattering function and AggregatorSpec for gathering function. |
|
GroovyIntegrationFlowDefinition |
scatterGather(Closure<?> scatterer, Closure<?> gatherer, Closure<?> scatterGather)Populate a ScatterGatherHandler to the current integration flow position based on the provided RecipientListRouterSpec for scattering function and AggregatorSpec for gathering function. |
|
GroovyIntegrationFlowDefinition |
split(Closure<?> endpointConfigurer)Populate the DefaultMessageSplitter with provided options to the current integration flow position. |
|
GroovyIntegrationFlowDefinition |
split(String expression, Closure<?> endpointConfigurer)Populate the ExpressionEvaluatingSplitter with provided SpEL expression. |
|
GroovyIntegrationFlowDefinition |
split(Object service, String methodName, Closure<?> endpointConfigurer)Populate the MethodInvokingSplitter to evaluate the provided method of the bean at runtime.
|
|
GroovyIntegrationFlowDefinition |
split(String beanName, String methodName, Closure<?> endpointConfigurer)Populate the MethodInvokingSplitter to evaluate the provided method of the bean at runtime.
|
|
GroovyIntegrationFlowDefinition |
split(MessageProcessorSpec<?> messageProcessorSpec, Closure<?> endpointConfigurer)Populate the MethodInvokingSplitter to evaluate the MessageProcessor at runtime from provided MessageProcessorSpec. |
<P> |
GroovyIntegrationFlowDefinition |
split(Class<P> expectedType, Function<P, ?> splitter, Closure<?> endpointConfigurer)Populate the MethodInvokingSplitter to evaluate the provided Function at runtime. |
<S extends AbstractMessageSplitter> |
GroovyIntegrationFlowDefinition |
split(MessageHandlerSpec<?, S> splitterMessageHandlerSpec, Closure<?> endpointConfigurer)Populate the provided AbstractMessageSplitter to the current integration flow position. |
<S extends AbstractMessageSplitter> |
GroovyIntegrationFlowDefinition |
split(S splitter, Closure<?> endpointConfigurer)Populate the provided AbstractMessageSplitter to the current integration flow position. |
|
GroovyIntegrationFlowDefinition |
transform(String expression, Closure<?> endpointConfigurer)Populate the Transformer EI Pattern specific MessageHandler implementation
for the SpEL org.springframework.expression.Expression. |
|
GroovyIntegrationFlowDefinition |
transform(Object service, String methodName, Closure<?> endpointConfigurer)Populate the MessageTransformingHandler for the
MethodInvokingTransformer
to invoke the service method at runtime. |
|
GroovyIntegrationFlowDefinition |
transform(MessageProcessorSpec<?> messageProcessorSpec, Closure<?> endpointConfigurer)Populate the MessageTransformingHandler instance for the MessageProcessor from provided MessageProcessorSpec. |
<P, T> |
GroovyIntegrationFlowDefinition |
transform(GenericTransformer<P, T> genericTransformer, Closure<?> endpointConfigurer)Populate the MessageTransformingHandler instance for the provided GenericTransformer for the specific expectedType to convert at runtime.
|
<P, T> |
GroovyIntegrationFlowDefinition |
transform(Class<P> expectedType, GenericTransformer<P, T> genericTransformer, Closure<?> endpointConfigurer)Populate the MessageTransformingHandler instance for the provided GenericTransformer for the specific expectedType to convert at runtime.
|
|
GroovyIntegrationFlowDefinition |
trigger(String triggerActionId, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler instance to perform MessageTriggerAction and endpoint options from GenericEndpointSpec. |
|
GroovyIntegrationFlowDefinition |
trigger(MessageTriggerAction triggerAction, Closure<?> endpointConfigurer)Populate a ServiceActivatingHandler instance to perform MessageTriggerAction and endpoint options from GenericEndpointSpec. |
|
GroovyIntegrationFlowDefinition |
wireTap(IntegrationFlow flow, Closure<?> wireTapConfigurer)Populate the Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current message channel.
|
|
GroovyIntegrationFlowDefinition |
wireTap(String wireTapChannel, Closure<?> wireTapConfigurer)Populate the Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current message channel.
|
|
GroovyIntegrationFlowDefinition |
wireTap(MessageChannel wireTapChannel, Closure<?> wireTapConfigurer)Populate the Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current current MessageChannel.
|
A short-cut for the aggregate((aggregator) -> aggregator.processor(aggregatorProcessor)).
aggregatorProcessor - the POJO representing aggregation strategies.Populate the AggregatingMessageHandler with provided options from AggregatorSpec. In addition, accept options for the integration endpoint using GenericEndpointSpec. Used with a Closure expression (optional).
aggregator - the Consumer to provide
AggregatingMessageHandler options.Populate a BarrierMessageHandler instance for provided timeout and options from BarrierSpec and endpoint options from GenericEndpointSpec.
timeout - the timeout in milliseconds.barrierConfigurer - the Consumer to provide
BarrierMessageHandler options.Populate a BridgeHandler to the current integration flow position. sed with a Closure expression.
endpointConfigurer - the Consumer to provide integration endpoint options. 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.
messageChannelName - the bean name to use.Populate a MessageChannel instance at the current IntegrationFlow chain position using the MessageChannelSpec fluent API.
messageChannelSpec - the MessageChannelSpec to use. 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.
messageChannel - the MessageChannel to populate.Populate a MessageChannel instance at the current IntegrationFlow chain position using the Channels factory fluent API.
channels - the Function to use.Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore. In addition accept options for the integration endpoint using GenericEndpointSpec.
messageStore - the MessageStore to use.endpointConfigurer - the Consumer to provide integration endpoint options. Populate the MessageTransformingHandler for the
ClaimCheckOutTransformer
with provided MessageStore and removeMessage flag.
In addition accept options for the integration endpoint using GenericEndpointSpec.
messageStore - the MessageStore to use.removeMessage - the removeMessage boolean flag.endpointConfigurer - the Consumer to provide integration endpoint options. Populate the Control Bus EI Pattern specific MessageHandler implementation
at the current IntegrationFlow chain position.
endpointConfigurer - the Consumer to accept integration endpoint options. Populate the MessageTransformingHandler instance
for the provided payloadType to convert at runtime.
In addition, accept options for the integration endpoint using GenericEndpointSpec.
payloadType - the Class for expected payload type.endpointConfigurer - the Consumer to provide integration endpoint options.< - P > the payload type - 'transform to'.Populate a DelayHandler to the current integration flow position.
groupId - the groupId for delayed messages in the
MessageGroupStore.endpointConfigurer - the Consumer to provide integration endpoint options.Populate a ContentEnricher to the current integration flow position with provided options. Used with a Closure expression.
enricherConfigurer - the Closure to provide
ContentEnricher options.Populate a MessageTransformingHandler for a HeaderEnricher as the result of provided Consumer.
headerEnricherConfigurer - the Consumer to use.Populate a MessageFilter with MessageSelector for the provided SpEL expression. In addition accept options for the integration endpoint using FilterEndpointSpec
expression - the SpEL expression.endpointConfigurer - the Consumer to provide integration endpoint options.Populate a MessageFilter with MethodInvokingSelector for the method of the provided service.
service - the service to use.methodName - the method to invokeendpointConfigurer - the Consumer to provide integration endpoint options.Populate a MessageFilter with MethodInvokingSelector for the MessageProcessor from the provided MessageProcessorSpec.
messageProcessorSpec - the MessageProcessorSpec to use.endpointConfigurer - the Consumer to provide integration endpoint options.Populate a MessageFilter with MethodInvokingSelector for the provided GenericSelector. In addition, accept options for the integration endpoint using FilterEndpointSpec.
expectedType - 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.< - P > the source payload type or Message.class. Populate an FixedSubscriberChannel instance
at the current IntegrationFlow chain position.
The provided messageChannelName is used for the bean registration.
messageChannelName - the bean name to use.Populate a FluxMessageChannel to start a reactive processing for upstream data, wrap it to a Flux, apply provided Function via Flux#transform(Function)#transform(Function) and emit the result to one more FluxMessageChannel, subscribed in the downstream flow.
fluxFunction - the Function to process data reactive manner.< - I > the input payload type.< - O > the output type. Populate the "artificial"
GatewayMessageHandler for the
provided requestChannel to send a request with options from
GatewayEndpointSpec. Uses
RequestReplyExchanger Proxy on the
background.
requestChannel - the MessageChannel bean name.endpointConfigurer - the Consumer to provide integration endpoint
options. Populate the "artificial"
GatewayMessageHandler for the
provided requestChannel to send a request with options from
GatewayEndpointSpec. Uses
RequestReplyExchanger Proxy on the
background.
requestChannel - the MessageChannel to use.endpointConfigurer - the Consumer to provide integration endpoint
options. Populate the "artificial"
GatewayMessageHandler for the
provided subflow with options from GatewayEndpointSpec.
Typically used with a Closure expression.
flow - the IntegrationFlow to to send a request message and wait for reply.endpointConfigurer - the Consumer to provide integration endpoint options. 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.
beanName - the bean name to use.methodName - the method to invoke.endpointConfigurer - the Consumer to provide integration endpoint options. 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.
service - the service object to use.methodName - the method to invoke.endpointConfigurer - the Consumer to provide integration endpoint options.Populate a ServiceActivatingHandler for the MethodInvokingMessageProcessor to invoke the provided GenericHandler at runtime. In addition accept options for the integration endpoint using GenericEndpointSpec.
expectedType - 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.< - P > the payload type to expect or Message.class.Populate a ServiceActivatingHandler for the MessageProcessor from the provided MessageProcessorSpec.
messageProcessorSpec - the MessageProcessorSpec to use.endpointConfigurer - the Consumer to provide integration endpoint options. Populate a ServiceActivatingHandler for the selected protocol specific
MessageHandler implementation from Namespace Factory:
In addition accept options for the integration endpoint using GenericEndpointSpec.
messageHandlerSpec - the MessageHandlerSpec to configure protocol specific
MessageHandler.endpointConfigurer - the Consumer to provide integration endpoint options.< - H > the MessageHandler type.Populate a ServiceActivatingHandler for the provided MessageHandler implementation. In addition accept options for the integration endpoint using GenericEndpointSpec.
messageHandler - the MessageHandler to use.endpointConfigurer - the Consumer to provide integration endpoint options.< - H > the MessageHandler type.Populate the provided MessageTransformingHandler for the provided HeaderFilter.
headerFilter - the HeaderFilter to use.endpointConfigurer - the Consumer to provide integration endpoint options.Add one or more ChannelInterceptor implementations to the current MessageChannel, in the given order, after any interceptors already registered.
interceptorArray - one or more ChannelInterceptors. Populate a WireTap for the current message channel
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.
level - the LoggingHandler.Level.Populate a WireTap for the current message channel 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.
level - the LoggingHandler.Level.category - the logging category.function - the function to evaluate logger message at runtime< - P > the expected payload type against the request Message.The PublishSubscribeChannel channel method specific implementation to allow the use of the 'subflow' subscriber capability.
executor - the Executor to use.publishSubscribeChannelConfigurer - the Consumer to specify
PublishSubscribeSpec options including 'subflow' definition.The BroadcastCapableChannel channel method specific implementation to allow the use of the 'subflow' subscriber capability.
broadcastCapableChannel - the BroadcastCapableChannel to subscriber sub-flows to.publishSubscribeChannelConfigurer - the Consumer to specify
BroadcastPublishSubscribeSpec 'subflow' definitions.Populate the ResequencingMessageHandler with provided options from ResequencerSpec. In addition accept options for the integration endpoint using GenericEndpointSpec. Used with a Closure expression (optional).
resequencer - the Consumer to provide
ResequencingMessageHandler options.Populate the MethodInvokingRouter for provided bean and its method with provided options from RouterSpec.
beanName - the bean to use.method - the method to invoke at runtime.routerConfigurer - the Consumer to provide MethodInvokingRouter options.Populate the MethodInvokingRouter for the method of the provided service and its method with provided options from RouterSpec.
service - the service to use.methodName - the method to invoke.routerConfigurer - the Consumer to provide MethodInvokingRouter options.Populate the ExpressionEvaluatingRouter for provided SpEL expression with provided options from RouterSpec.
expression - the expression to use.routerConfigurer - the Consumer to provide ExpressionEvaluatingRouter options.< - T > the target result type.Populate the MethodInvokingRouter for provided Function and payload type and options from RouterSpec. In addition, accept options for the integration endpoint using GenericEndpointSpec.
expectedType - the Class for expected payload type. It can also be
Message.class if you wish to access the entire message in the router.
Conversion to this type will be attempted, if necessary.router - the Function to use.routerConfigurer - the Consumer to provide MethodInvokingRouter options.< - P > the source payload type or Message.class.< - T > the target result type.Populate the MethodInvokingRouter for the MessageProcessor from the provided MessageProcessorSpec with default options.
messageProcessorSpec - the MessageProcessorSpec to use.routerConfigurer - the Consumer to provide MethodInvokingRouter options.Populate the provided AbstractMessageRouter implementation to the current integration flow position. In addition accept options for the integration endpoint using GenericEndpointSpec.
router - the AbstractMessageRouter to populate.endpointConfigurer - the Consumer to provide integration endpoint options. - > the AbstractMessageRouter type. Populate the ErrorMessageExceptionTypeRouter with options from the RouterSpec. Typically used with a Closure expression.
routerConfigurer - the Consumer to provide ErrorMessageExceptionTypeRouter options.Populate the RecipientListRouter with options from the RecipientListRouterSpec. Typically used with a Closure expression.
routerConfigurer - the Consumer to provide
RecipientListRouter options.Populate a ScatterGatherHandler to the current integration flow position based on the provided MessageChannel for scattering function and AggregatorSpec for gathering function.
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.Populate a ScatterGatherHandler to the current integration flow position based on the provided RecipientListRouterSpec for scattering function and AggregatorSpec for gathering function.
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.Populate the DefaultMessageSplitter with provided options to the current integration flow position. Used with a Closure expression (optional).
endpointConfigurer - the Consumer to provide integration endpoint options
and for DefaultMessageSplitter.Populate the ExpressionEvaluatingSplitter with provided SpEL expression.
expression - the splitter SpEL expression.endpointConfigurer - the Consumer to provide integration endpoint options
and for ExpressionEvaluatingSplitter. Populate the MethodInvokingSplitter to evaluate the provided
method of the bean at runtime.
In addition accept options for the integration endpoint using GenericEndpointSpec.
service - the service to use.methodName - the method to invoke.endpointConfigurer - the Consumer to provide integration endpoint options
and for MethodInvokingSplitter. Populate the MethodInvokingSplitter to evaluate the provided
method of the bean at runtime.
In addition accept options for the integration endpoint using GenericEndpointSpec.
beanName - the bean name to use.methodName - the method to invoke at runtime.endpointConfigurer - the Consumer to provide integration endpoint options
and for MethodInvokingSplitter.Populate the MethodInvokingSplitter to evaluate the MessageProcessor at runtime from provided MessageProcessorSpec. In addition accept options for the integration endpoint using GenericEndpointSpec.
messageProcessorSpec - the splitter MessageProcessorSpec.endpointConfigurer - the Consumer to provide integration endpoint options
and for MethodInvokingSplitter.Populate the MethodInvokingSplitter to evaluate the provided Function at runtime. In addition, accept options for the integration endpoint using GenericEndpointSpec.
expectedType - 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.< - P > the payload type or Message.class.Populate the provided AbstractMessageSplitter to the current integration flow position.
splitterMessageHandlerSpec - the MessageHandlerSpec to populate.endpointConfigurer - the Consumer to provide integration endpoint options.< - S > the AbstractMessageSplitterPopulate the provided AbstractMessageSplitter to the current integration flow position.
splitter - the AbstractMessageSplitter to populate.endpointConfigurer - the Consumer to provide integration endpoint options.< - S > the AbstractMessageSplitter Populate the Transformer EI Pattern specific MessageHandler implementation
for the SpEL org.springframework.expression.Expression.
expression - the Transformer org.springframework.expression.Expression.endpointConfigurer - the Consumer to provide integration endpoint options. Populate the MessageTransformingHandler for the
MethodInvokingTransformer
to invoke the service method at runtime.
service - the service to use.methodName - the method to invoke.endpointConfigurer - the Consumer to provide integration endpoint options.Populate the MessageTransformingHandler instance for the MessageProcessor from provided MessageProcessorSpec. In addition accept options for the integration endpoint using GenericEndpointSpec.
messageProcessorSpec - the MessageProcessorSpec to use.endpointConfigurer - the Consumer to provide integration endpoint options. Populate the MessageTransformingHandler instance for the provided GenericTransformer
for the specific expectedType to convert at runtime.
In addition accept options for the integration endpoint using GenericEndpointSpec.
expectedType - 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.< - P > the payload type - 'transform from', or Message.class.< - T > the target type - 'transform to'. Populate the MessageTransformingHandler instance for the provided GenericTransformer
for the specific expectedType to convert at runtime.
In addition accept options for the integration endpoint using GenericEndpointSpec.
expectedType - 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.< - P > the payload type - 'transform from', or Message.class.< - T > the target type - 'transform to'.Populate a ServiceActivatingHandler instance to perform MessageTriggerAction and endpoint options from GenericEndpointSpec.
triggerActionId - the MessageTriggerAction bean id.endpointConfigurer - the Consumer to provide integration endpoint options.Populate a ServiceActivatingHandler instance to perform MessageTriggerAction and endpoint options from GenericEndpointSpec.
triggerAction - the MessageTriggerAction.endpointConfigurer - the Consumer to provide integration endpoint options. Populate the Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current message channel.
It is useful when an implicit MessageChannel is used between endpoints.
This method can be used after any channel for explicit MessageChannel,
but with the caution do not impact existing ChannelInterceptors.
flow - the IntegrationFlow for wire-tap subflow as an alternative to the wireTapChannel.wireTapConfigurer - the Consumer to accept options for the
WireTap. Populate the Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current message channel.
It is useful when an implicit MessageChannel is used between endpoints.
This method can be used after any channel for explicit MessageChannel,
but with the caution do not impact existing ChannelInterceptors.
wireTapChannel - the MessageChannel bean name to wire-tap.wireTapConfigurer - the Consumer to accept options for the
WireTap. Populate the Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current current MessageChannel.
It is useful when an implicit MessageChannel is used between endpoints.
This method can be used after any channel for explicit MessageChannel,
but with the caution do not impact existing ChannelInterceptors.
wireTapChannel - the MessageChannel to wire-tap.wireTapConfigurer - the Consumer to accept options for the
WireTap.