Package org.springframework.integration.endpoint

@NullMarked package org.springframework.integration.endpoint

Provides core classes related to Endpoints.

Related Packages

Package	Description
org.springframework.integration	Base package for Spring Integration Core.

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 subclass that provides ExpressionMessageProducerSupport.payloadExpression evaluation with result as a payload for Message to send.
IntegrationConsumer	Message consumers implement this interface, the message handler within a consumer may or may not emit output messages.
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.
PollingOperations	Operations to perform on some message source.
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.