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.
Base interface for any source of
Messages
that can be polled.- Author:
- Mark Fisher, Artem Bilan
-
Method Summary
Modifier and TypeMethodDescriptiondefault IntegrationPatternType
Return a pattern type this component implements.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.
-