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,JdbcPollingChannelAdapter,JmsDestinationPollingSource,JpaPollingChannelAdapter,KafkaMessageSource,MailReceivingMessageSource,MBeanTreePollingMessageSource,MessageProcessorMessageSource,MethodInvokingMessageSource,MongoDbMessageSource,R2dbcMessageSource,ReactiveMongoDbMessageSource,RedisStoreMessageSource,ResourceRetrievingMessageSource,ScriptExecutingMessageSource,SftpInboundFileSynchronizingMessageSource,SftpStreamingMessageSource,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
-
Method Summary
Modifier and Type Method Description default IntegrationPatternTypegetIntegrationPatternType()Return a pattern type this component implements.Message<T>receive()Retrieve the next available message from this source.
-
Method Details
-
receive
Retrieve the next available message from this source. Returnsnullif no message is available.- Returns:
- The message or null.
-
getIntegrationPatternType
Description copied from interface:IntegrationPatternReturn a pattern type this component implements.- Specified by:
getIntegrationPatternTypein interfaceIntegrationPattern- Returns:
- the
IntegrationPatternTypethis component implements.
-