Package org.springframework.integration.endpoint
package org.springframework.integration.endpoint
Provides core classes related to Endpoints.
-
ClassDescriptionThe base class for Message Endpoint implementations.A message source that can limit the number of remote objects it fetches.Abstract message source.An
AbstractEndpoint
extension for Polling Consumer pattern basics.Message Endpoint that connects anyMessageHandler
implementation to aSubscribableChannel
.AMessageProducerSupport
sub-class that provides ExpressionMessageProducerSupport.payloadExpression evaluation with result as a payload for Message to send.Message consumers implement this interface, the message handler within a consumer may or may not emit output messages.TheMessageSource
strategy implementation to produce aMessage
from underlying MessageProcessorMessageSource.messageProcessor for polling endpoints.A support class for producer endpoints that provides a setter for the output channel and a convenience method for sending Messages.APollingOperations
used to ad-hoc poll aMessageSource
.AMessageSource
implementation that invokes a no-argument method so that its return value may be sent to a channel.Message Endpoint that connects anyMessageHandler
implementation to aPollableChannel
.Operations to perform on some message source.TheMessageProducerSupport
to adapt a providedMessageSource
into aFlux
and let it be subscribed in theMessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>)
.AnAbstractEndpoint
implementation for Reactive Streams subscription into an input channel and reactive consumption of messages from that channel.A Channel Adapter implementation for connecting aMessageSource
to aMessageChannel
.