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 | |
| 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. |