Package org.springframework.integration.endpoint
Provides core classes related to Endpoints.
-
Interface Summary Interface Description IntegrationConsumer Message consumers implement this interface, the message handler within a consumer may or may not emit output messages.PollingOperations Operations to perform on some message source. -
Class Summary Class Description AbstractEndpoint The base class for Message Endpoint implementations.AbstractFetchLimitingMessageSource<T> A message source that can limit the number of remote objects it fetches.AbstractMessageSource<T> Abstract message source.AbstractPollingEndpoint AnAbstractEndpointextension for Polling Consumer pattern basics.EventDrivenConsumer Message Endpoint that connects anyMessageHandlerimplementation to aSubscribableChannel.ExpressionEvaluatingMessageSource<T> ExpressionMessageProducerSupport AMessageProducerSupportsub-class that provides ExpressionMessageProducerSupport.payloadExpression evaluation with result as a payload for Message to send.MessageProcessorMessageSource TheMessageSourcestrategy implementation to produce aMessagefrom underlying MessageProcessorMessageSource.messageProcessor for polling endpoints.MessageProducerSupport A support class for producer endpoints that provides a setter for the output channel and a convenience method for sending Messages.MessageSourcePollingTemplate APollingOperationsused to ad-hoc poll aMessageSource.MethodInvokingMessageSource AMessageSourceimplementation that invokes a no-argument method so that its return value may be sent to a channel.PollingConsumer Message Endpoint that connects anyMessageHandlerimplementation to aPollableChannel.ReactiveMessageSourceProducer TheMessageProducerSupportto adapt a providedMessageSourceinto aFluxand let it be subscribed in theMessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>).ReactiveStreamsConsumer AnAbstractEndpointimplementation for Reactive Streams subscription into an input channel and reactive consumption of messages from that channel.SourcePollingChannelAdapter A Channel Adapter implementation for connecting aMessageSourceto aMessageChannel.