Uses of Class
org.springframework.integration.dsl.GenericEndpointSpec
Package
Description
Root package of the Spring Integration Java DSL.
-
Uses of GenericEndpointSpec in org.springframework.integration.dsl
Modifier and TypeMethodDescriptionBaseIntegrationFlowDefinition.bridge
(Consumer<GenericEndpointSpec<BridgeHandler>> endpointConfigurer) Populate aBridgeHandler
to the current integration flow position.BaseIntegrationFlowDefinition.claimCheckIn
(MessageStore messageStore, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) BaseIntegrationFlowDefinition.claimCheckOut
(MessageStore messageStore, boolean removeMessage, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate theMessageTransformingHandler
for theClaimCheckOutTransformer
with providedMessageStore
andremoveMessage
flag.BaseIntegrationFlowDefinition.controlBus
(Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate theControl Bus
EI Pattern specificMessageHandler
implementation at the currentIntegrationFlow
chain position.<P> B
BaseIntegrationFlowDefinition.convert
(Class<P> payloadType, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate theMessageTransformingHandler
instance for the providedpayloadType
to convert at runtime.BaseIntegrationFlowDefinition.enrichHeaders
(Map<String, Object> headers, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) BaseIntegrationFlowDefinition.enrichHeaders
(MapBuilder<?, String, Object> headers, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate aMessageTransformingHandler
for aHeaderEnricher
using header values from providedMapBuilder
.<H extends MessageHandler>
BBaseIntegrationFlowDefinition.handle
(H messageHandler, Consumer<GenericEndpointSpec<H>> endpointConfigurer) Populate aServiceActivatingHandler
for the providedMessageHandler
implementation.<P> B
BaseIntegrationFlowDefinition.handle
(Class<P> expectedType, GenericHandler<P> handler, Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate aServiceActivatingHandler
for theMethodInvokingMessageProcessor
to invoke the providedGenericHandler
at runtime.BaseIntegrationFlowDefinition.handle
(Object service, String methodName, Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate aServiceActivatingHandler
for theMethodInvokingMessageProcessor
to invoke themethod
for providedbean
at runtime.BaseIntegrationFlowDefinition.handle
(String beanName, String methodName, Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate aServiceActivatingHandler
for theMethodInvokingMessageProcessor
to invoke themethod
for providedbean
at runtime.<H extends MessageHandler>
BBaseIntegrationFlowDefinition.handle
(MessageHandlerSpec<?, H> messageHandlerSpec, Consumer<GenericEndpointSpec<H>> endpointConfigurer) Populate aServiceActivatingHandler
for the selected protocol specificMessageHandler
implementation from the respective namespace factory (e.g.BaseIntegrationFlowDefinition.handle
(MessageProcessorSpec<?> messageProcessorSpec, Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate aServiceActivatingHandler
for theMessageProcessor
from the providedMessageProcessorSpec
.<P> B
IntegrationFlowDefinition.handle
(GenericHandler<P> handler, Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate aServiceActivatingHandler
for theMethodInvokingMessageProcessor
to invoke the providedGenericHandler
at runtime.<H extends ReactiveMessageHandler>
IntegrationFlowBaseIntegrationFlowDefinition.handleReactive
(ReactiveMessageHandlerSpec<?, H> messageHandlerSpec, Consumer<GenericEndpointSpec<ReactiveMessageHandlerAdapter>> endpointConfigurer) Populate a terminal consumer endpoint for the selected protocol specificMessageHandler
implementation from the respective namespace factory (e.g.BaseIntegrationFlowDefinition.handleReactive
(ReactiveMessageHandler reactiveMessageHandler, Consumer<GenericEndpointSpec<ReactiveMessageHandlerAdapter>> endpointConfigurer) Add aReactiveMessageHandler
as a terminalIntegrationFlow
operator.BaseIntegrationFlowDefinition.headerFilter
(HeaderFilter headerFilter, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate the providedMessageTransformingHandler
for the providedHeaderFilter
.<R extends AbstractMessageRouter>
BBaseIntegrationFlowDefinition.route
(R router, Consumer<GenericEndpointSpec<R>> endpointConfigurer) Populate the providedAbstractMessageRouter
implementation to the current integration flow position.<P,
T> B BaseIntegrationFlowDefinition.transform
(Class<P> expectedType, GenericTransformer<P, T> genericTransformer, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate theMessageTransformingHandler
instance for the providedGenericTransformer
for the specificexpectedType
to convert at runtime.BaseIntegrationFlowDefinition.transform
(Object service, String methodName, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate theMessageTransformingHandler
for theMethodInvokingTransformer
to invoke the service method at runtime.BaseIntegrationFlowDefinition.transform
(String expression, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) BaseIntegrationFlowDefinition.transform
(MessageProcessorSpec<?> messageProcessorSpec, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate theMessageTransformingHandler
instance for theMessageProcessor
from providedMessageProcessorSpec
.<S,
T> B IntegrationFlowDefinition.transform
(GenericTransformer<S, T> genericTransformer, Consumer<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) Populate theMessageTransformingHandler
instance for the providedGenericTransformer
.BaseIntegrationFlowDefinition.trigger
(String triggerActionId, Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate aServiceActivatingHandler
instance to performMessageTriggerAction
and endpoint options fromGenericEndpointSpec
.BaseIntegrationFlowDefinition.trigger
(MessageTriggerAction triggerAction, Consumer<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) Populate aServiceActivatingHandler
instance to performMessageTriggerAction
and endpoint options fromGenericEndpointSpec
.