See: Description
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 | 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 . |