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	An AbstractEndpoint extension for Polling Consumer pattern basics.
EventDrivenConsumer	Message Endpoint that connects any MessageHandler implementation to a SubscribableChannel.
ExpressionEvaluatingMessageSource<T>
ExpressionMessageProducerSupport	A MessageProducerSupport sub-class that provides ExpressionMessageProducerSupport.payloadExpression evaluation with result as a payload for Message to send.
MessageProcessorMessageSource	The MessageSource strategy implementation to produce a Message from 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	A PollingOperations used to ad-hoc poll a MessageSource.
MethodInvokingMessageSource	A MessageSource implementation that invokes a no-argument method so that its return value may be sent to a channel.
PollingConsumer	Message Endpoint that connects any MessageHandler implementation to a PollableChannel.
ReactiveMessageSourceProducer	The MessageProducerSupport to adapt a provided MessageSource into a Flux and let it be subscribed in the MessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>)
ReactiveStreamsConsumer	An AbstractEndpoint implementation for Reactive Streams subscription into an input channel and reactive consumption of messages from that channel.
SourcePollingChannelAdapter	A Channel Adapter implementation for connecting a MessageSource to a MessageChannel.