Interface MessageSource<T>
- 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 IntegrationPatternType
getIntegrationPatternType()
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. Returnsnull
if no message is available.- Returns:
- The message or null.
-
getIntegrationPatternType
Description copied from interface:IntegrationPattern
Return a pattern type this component implements.- Specified by:
getIntegrationPatternType
in interfaceIntegrationPattern
- Returns:
- the
IntegrationPatternType
this component implements.
-