Interface MessageSource<T>

Type Parameters:
T - the expected payload type.
All Superinterfaces:
IntegrationPattern
All Known Implementing Classes:
AbstractFetchLimitingMessageSource, AbstractInboundFileSynchronizingMessageSource, AbstractMessageSource, AbstractMongoDbMessageSource, AbstractRemoteFileStreamingMessageSource, AmqpMessageSource, AttributePollingMessageSource, ByteStreamReadingMessageSource, CharacterStreamReadingMessageSource, CorrelatingMessageBarrier, ExpressionEvaluatingMessageSource, FeedEntryMessageSource, FileReadingMessageSource, FtpInboundFileSynchronizingMessageSource, FtpStreamingMessageSource, HazelcastDistributedSQLMessageSource, JdbcPollingChannelAdapter, JmsDestinationPollingSource, JpaPollingChannelAdapter, KafkaMessageSource, MailReceivingMessageSource, MBeanTreePollingMessageSource, MessageProcessorMessageSource, MethodInvokingMessageSource, MongoDbMessageSource, R2dbcMessageSource, ReactiveMongoDbMessageSource, RedisStoreMessageSource, ResourceRetrievingMessageSource, ScriptExecutingMessageSource, SftpInboundFileSynchronizingMessageSource, SftpStreamingMessageSource, SmbInboundFileSynchronizingMessageSource, SmbStreamingMessageSource, StoredProcPollingChannelAdapter
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface MessageSource<T> extends IntegrationPattern
Base interface for any source of Messages that can be polled.
Author:
Mark Fisher, Artem Bilan