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
AbstractEndpointextension for Polling Consumer pattern basics.Message Endpoint that connects anyMessageHandlerimplementation to aSubscribableChannel.AMessageProducerSupportsub-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.TheMessageSourcestrategy implementation to produce aMessagefrom 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.APollingOperationsused to ad-hoc poll aMessageSource.AMessageSourceimplementation that invokes a no-argument method so that its return value may be sent to a channel.Message Endpoint that connects anyMessageHandlerimplementation to aPollableChannel.Operations to perform on some message source.TheMessageProducerSupportto adapt a providedMessageSourceinto aFluxand let it be subscribed in theMessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>).AnAbstractEndpointimplementation for Reactive Streams subscription into an input channel and reactive consumption of messages from that channel.A Channel Adapter implementation for connecting aMessageSourceto aMessageChannel.