Uses of Interface
org.springframework.integration.core.MessageSource

Packages that use MessageSource

Package	Description
org.springframework.integration.aggregator	Provides classes related to message aggregation.
org.springframework.integration.amqp.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.aop	Provides classes to support message publication using AOP.
org.springframework.integration.config	Base package for configuration.
org.springframework.integration.dsl	Root package of the Spring Integration Java DSL.
org.springframework.integration.endpoint	Provides core classes related to Endpoints.
org.springframework.integration.feed.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.file	Base package for File support.
org.springframework.integration.file.config	Provides classes for configuration - parsers, namespace handlers, factory beans.
org.springframework.integration.file.remote	Base package for supporting remote files.
org.springframework.integration.file.remote.aop	Provides classes related to AOP.
org.springframework.integration.file.remote.synchronizer	Provides classes supporting the synchronization of remote and local file directories.
org.springframework.integration.ftp.config	Provides classes for configuration - parsers, namespace handlers.
org.springframework.integration.ftp.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.graph	Provides classes related to the runtime object graph.
org.springframework.integration.hazelcast.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.jdbc	Root package of the Spring Integration JDBC module, which contains various JDBC and Stored Procedure/Function supporting components.
org.springframework.integration.jms	Base package for JMS Support.
org.springframework.integration.jmx	Base package for JMX support.
org.springframework.integration.jpa.inbound	Provides inbound Spring Integration Jpa components.
org.springframework.integration.kafka.inbound	Provides Spring Integration inbound components for Apache Kafka.
org.springframework.integration.mail	Base package for Mail support.
org.springframework.integration.mongodb.inbound	Provides classes related to the Mongo inbound channel adapters
org.springframework.integration.r2dbc.inbound	Provides classes for supporting R2DBC inbound components.
org.springframework.integration.redis.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.resource	Provides classes related to messaging using Spring Resources
org.springframework.integration.scripting	Base package for scripting support.
org.springframework.integration.scripting.dsl	Provides Scripting Components support for Spring Integration Java DSL.
org.springframework.integration.sftp.config	Provides classes for configuration - parsers, namespace handlers.
org.springframework.integration.sftp.inbound	Provides classes supporting inbound endpoints.
org.springframework.integration.smb.config	SMB-specific file list filter classes.
org.springframework.integration.smb.inbound	Inbound Channel Adapters implementations for SMB protocol.
org.springframework.integration.stream	Base package for stream support.
org.springframework.integration.test.context	Test context-related components.
org.springframework.integration.test.mock	Utilities for mocking integration components.
org.springframework.integration.util	Provides core utility classes.

Uses of MessageSource in org.springframework.integration.aggregator

Classes in org.springframework.integration.aggregator that implement MessageSource

Modifier and Type	Class	Description
class	CorrelatingMessageBarrier	This Endpoint serves as a barrier for messages that should not be processed yet.

Uses of MessageSource in org.springframework.integration.amqp.inbound

Classes in org.springframework.integration.amqp.inbound that implement MessageSource

Modifier and Type	Class	Description
class	AmqpMessageSource	A pollable MessageSource for RabbitMQ.

Uses of MessageSource in org.springframework.integration.aop

Methods in org.springframework.integration.aop with parameters of type MessageSource

Modifier and Type	Method	Description
Message<?>	CompoundTriggerAdvice.afterReceive(Message<?> result, MessageSource<?> source)
Message<?>	MessageSourceMutator.afterReceive(Message<?> result, MessageSource<?> source)	Subclasses can take actions based on the result of the poll; e.g.
default boolean	MessageSourceMutator.beforeReceive(MessageSource<?> source)	Subclasses can decide whether to proceed with this poll.

Uses of MessageSource in org.springframework.integration.config

Methods in org.springframework.integration.config with parameters of type MessageSource

Modifier and Type	Method	Description
void	SourcePollingChannelAdapterFactoryBean.setSource(MessageSource<?> source)

Uses of MessageSource in org.springframework.integration.dsl

Classes in org.springframework.integration.dsl with type parameters of type MessageSource

Modifier and Type	Class	Description
class	MessageSourceSpec<S extends MessageSourceSpec<S,H>,H extends MessageSource<?>>	An IntegrationComponentSpec for MessageSources.

Subclasses with type arguments of type MessageSource in org.springframework.integration.dsl

Modifier and Type	Class	Description
class	SourcePollingChannelAdapterSpec

Methods in org.springframework.integration.dsl with parameters of type MessageSource

Modifier and Type	Method	Description
static IntegrationFlowBuilder	IntegrationFlow.from(MessageSource<?> messageSource)	Populate the provided MessageSource object to the IntegrationFlowBuilder chain.
static IntegrationFlowBuilder	IntegrationFlow.from(MessageSource<?> messageSource, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)	Populate the provided MessageSource object to the IntegrationFlowBuilder chain.
protected IntegrationFlowDefinition<?>	IntegrationFlowAdapter.from(MessageSource<?> messageSource)
protected IntegrationFlowDefinition<?>	IntegrationFlowAdapter.from(MessageSource<?> messageSource, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)

Method parameters in org.springframework.integration.dsl with type arguments of type MessageSource

Modifier and Type	Method	Description
static IntegrationFlowBuilder	IntegrationFlow.from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec)	Populate the MessageSource object to the IntegrationFlowBuilder chain using the fluent API from the provided MessageSourceSpec.
static IntegrationFlowBuilder	IntegrationFlow.from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)	Populate the MessageSource object to the IntegrationFlowBuilder chain using the fluent API from the provided MessageSourceSpec.
protected IntegrationFlowDefinition<?>	IntegrationFlowAdapter.from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec)
protected IntegrationFlowDefinition<?>	IntegrationFlowAdapter.from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)

Constructors in org.springframework.integration.dsl with parameters of type MessageSource

Modifier	Constructor	Description
protected	SourcePollingChannelAdapterSpec(MessageSource<?> messageSource)

Uses of MessageSource in org.springframework.integration.endpoint

Classes in org.springframework.integration.endpoint that implement MessageSource

Modifier and Type	Class	Description
class	AbstractFetchLimitingMessageSource<T>	A message source that can limit the number of remote objects it fetches.
class	AbstractMessageSource<T>	Abstract message source.
class	ExpressionEvaluatingMessageSource<T>
class	MessageProcessorMessageSource	The MessageSource strategy implementation to produce a Message from underlying MessageProcessorMessageSource.messageProcessor for polling endpoints.
class	MethodInvokingMessageSource	A MessageSource implementation that invokes a no-argument method so that its return value may be sent to a channel.

Methods in org.springframework.integration.endpoint that return MessageSource

Modifier and Type	Method	Description
MessageSource<?>	SourcePollingChannelAdapter.getMessageSource()	Return this endpoint's source.

Methods in org.springframework.integration.endpoint with parameters of type MessageSource

Modifier and Type	Method	Description
void	SourcePollingChannelAdapter.setSource(MessageSource<?> source)	Specify the source to be polled for Messages.

Constructors in org.springframework.integration.endpoint with parameters of type MessageSource

Modifier	Constructor	Description
	MessageSourcePollingTemplate(MessageSource<?> source)
	ReactiveMessageSourceProducer(MessageSource<?> messageSource)	Create an instance based on the provided MessageSource.

Uses of MessageSource in org.springframework.integration.feed.inbound

Classes in org.springframework.integration.feed.inbound that implement MessageSource

Modifier and Type	Class	Description
class	FeedEntryMessageSource	This implementation of MessageSource will produce individual SyndEntrys for a feed identified with the 'feedUrl' attribute.

Uses of MessageSource in org.springframework.integration.file

Classes in org.springframework.integration.file that implement MessageSource

Modifier and Type	Class	Description
class	FileReadingMessageSource	MessageSource that creates messages from a file system directory.

Uses of MessageSource in org.springframework.integration.file.config

Methods in org.springframework.integration.file.config that return types with arguments of type MessageSource

Modifier and Type	Method	Description
protected abstract Class<? extends MessageSource<?>>	AbstractRemoteFileStreamingInboundChannelAdapterParser.getMessageSourceClass()

Uses of MessageSource in org.springframework.integration.file.remote

Classes in org.springframework.integration.file.remote that implement MessageSource

Modifier and Type	Class	Description
class	AbstractRemoteFileStreamingMessageSource<F>	A message source that produces a message with an InputStream payload referencing a remote file.

Uses of MessageSource in org.springframework.integration.file.remote.aop

Methods in org.springframework.integration.file.remote.aop with parameters of type MessageSource

Modifier and Type	Method	Description
Message<?>	RotatingServerAdvice.afterReceive(Message<?> result, MessageSource<?> source)
void	RotationPolicy.afterReceive(boolean messageReceived, MessageSource<?> source)	Invoked after the message source receive() method.
void	StandardRotationPolicy.afterReceive(boolean messageReceived, MessageSource<?> source)
boolean	RotatingServerAdvice.beforeReceive(MessageSource<?> source)
void	RotationPolicy.beforeReceive(MessageSource<?> source)	Invoked before the message source receive() method.
void	StandardRotationPolicy.beforeReceive(MessageSource<?> source)
protected void	StandardRotationPolicy.configureSource(MessageSource<?> source)
protected void	StandardRotationPolicy.onRotation(MessageSource<?> source)	Update the state of the MessageSource after the server is rotated, if necessary.

Uses of MessageSource in org.springframework.integration.file.remote.synchronizer

Classes in org.springframework.integration.file.remote.synchronizer that implement MessageSource

Modifier and Type	Class	Description
class	AbstractInboundFileSynchronizingMessageSource<F>	Factors out the common logic between the FTP and SFTP adapters.

Uses of MessageSource in org.springframework.integration.ftp.config

Methods in org.springframework.integration.ftp.config that return types with arguments of type MessageSource

Modifier and Type	Method	Description
protected Class<? extends MessageSource<?>>	FtpStreamingInboundChannelAdapterParser.getMessageSourceClass()

Uses of MessageSource in org.springframework.integration.ftp.inbound

Classes in org.springframework.integration.ftp.inbound that implement MessageSource

Modifier and Type	Class	Description
class	FtpInboundFileSynchronizingMessageSource	A MessageSource implementation for FTP.
class	FtpStreamingMessageSource	Message source for streaming FTP remote file contents.

Uses of MessageSource in org.springframework.integration.graph

Constructors in org.springframework.integration.graph with parameters of type MessageSource

Modifier	Constructor	Description
	MessageSourceNode(int nodeId, String name, MessageSource<?> messageSource, String output, String errors)

Uses of MessageSource in org.springframework.integration.hazelcast.inbound

Classes in org.springframework.integration.hazelcast.inbound that implement MessageSource

Modifier and Type	Class	Description
class	HazelcastDistributedSQLMessageSource	Hazelcast Distributed SQL Message Source is a message source which runs defined distributed query in the cluster and returns results in the light of iteration type.

Uses of MessageSource in org.springframework.integration.jdbc

Classes in org.springframework.integration.jdbc that implement MessageSource

Modifier and Type	Class	Description
class	JdbcPollingChannelAdapter	A polling channel adapter that creates messages from the payload returned by executing a select query.
class	StoredProcPollingChannelAdapter	A polling channel adapter that creates messages from the payload returned by executing a stored procedure or Sql function.

Uses of MessageSource in org.springframework.integration.jms

Classes in org.springframework.integration.jms that implement MessageSource

Modifier and Type	Class	Description
class	JmsDestinationPollingSource	A source for receiving JMS Messages with a polling listener.

Uses of MessageSource in org.springframework.integration.jmx

Classes in org.springframework.integration.jmx that implement MessageSource

Modifier and Type	Class	Description
class	AttributePollingMessageSource	A MessageSource implementation that retrieves the current value of a JMX attribute each time AbstractMessageSource.receive() is invoked.
class	MBeanTreePollingMessageSource	A MessageSource implementation that retrieves a snapshot of a filtered subset of the MBean tree.

Uses of MessageSource in org.springframework.integration.jpa.inbound

Classes in org.springframework.integration.jpa.inbound that implement MessageSource

Modifier and Type	Class	Description
class	JpaPollingChannelAdapter	Polling message source that produces messages from the result of the provided: entityClass JpQl Select Query Sql Native Query JpQl Named Query Sql Native Named Query .

Uses of MessageSource in org.springframework.integration.kafka.inbound

Classes in org.springframework.integration.kafka.inbound that implement MessageSource

Modifier and Type	Class	Description
class	KafkaMessageSource<K,V>	Polled message source for Apache Kafka.

Uses of MessageSource in org.springframework.integration.mail

Classes in org.springframework.integration.mail that implement MessageSource

Modifier and Type	Class	Description
class	MailReceivingMessageSource	MessageSource implementation that delegates to a MailReceiver to poll a mailbox.

Uses of MessageSource in org.springframework.integration.mongodb.inbound

Classes in org.springframework.integration.mongodb.inbound that implement MessageSource

Modifier and Type	Class	Description
class	AbstractMongoDbMessageSource<T>	An AbstractMessageSource extension for common MongoDB sources options and support methods.
class	MongoDbMessageSource	An instance of MessageSource which returns a Message with a payload which is the result of execution of a Query.
class	ReactiveMongoDbMessageSource	An instance of MessageSource which returns a Message with a payload which is the result of execution of a Query.

Uses of MessageSource in org.springframework.integration.r2dbc.inbound

Classes in org.springframework.integration.r2dbc.inbound that implement MessageSource

Modifier and Type	Class	Description
class	R2dbcMessageSource	An instance of MessageSource which returns a Message with a payload which is the result of execution of query.

Uses of MessageSource in org.springframework.integration.redis.inbound

Classes in org.springframework.integration.redis.inbound that implement MessageSource

Modifier and Type	Class	Description
class	RedisStoreMessageSource	Inbound channel adapter which returns a Message representing a view into a Redis store.

Uses of MessageSource in org.springframework.integration.resource

Classes in org.springframework.integration.resource that implement MessageSource

Modifier and Type	Class	Description
class	ResourceRetrievingMessageSource	Implementation of MessageSource based on ResourcePatternResolver which will attempt to resolve Resources based on the pattern specified.

Uses of MessageSource in org.springframework.integration.scripting

Classes in org.springframework.integration.scripting that implement MessageSource

Modifier and Type	Class	Description
class	ScriptExecutingMessageSource	The MessageSource strategy implementation to produce a Message from underlying ScriptExecutingMessageSource.scriptMessageProcessor for polling endpoints.

Uses of MessageSource in org.springframework.integration.scripting.dsl

Subclasses with type arguments of type MessageSource in org.springframework.integration.scripting.dsl

Modifier and Type	Class	Description
class	ScriptMessageSourceSpec	The MessageSourceSpec for Dynamic Language Scripts.

Methods in org.springframework.integration.scripting.dsl that return MessageSource

Modifier and Type	Method	Description
protected MessageSource<?>	ScriptMessageSourceSpec.doGet()

Uses of MessageSource in org.springframework.integration.sftp.config

Methods in org.springframework.integration.sftp.config that return types with arguments of type MessageSource

Modifier and Type	Method	Description
protected Class<? extends MessageSource<?>>	SftpStreamingInboundChannelAdapterParser.getMessageSourceClass()

Uses of MessageSource in org.springframework.integration.sftp.inbound

Classes in org.springframework.integration.sftp.inbound that implement MessageSource

Modifier and Type	Class	Description
class	SftpInboundFileSynchronizingMessageSource	A MessageSource implementation for SFTP that delegates to an InboundFileSynchronizer.
class	SftpStreamingMessageSource	Message source for streaming SFTP remote file contents.

Uses of MessageSource in org.springframework.integration.smb.config

Methods in org.springframework.integration.smb.config that return types with arguments of type MessageSource

Modifier and Type	Method	Description
protected Class<? extends MessageSource<?>>	SmbStreamingInboundChannelAdapterParser.getMessageSourceClass()

Uses of MessageSource in org.springframework.integration.smb.inbound

Classes in org.springframework.integration.smb.inbound that implement MessageSource

Modifier and Type	Class	Description
class	SmbInboundFileSynchronizingMessageSource	A MessageSource implementation for SMB.
class	SmbStreamingMessageSource	Message source for streaming SMB remote file contents.

Uses of MessageSource in org.springframework.integration.stream

Classes in org.springframework.integration.stream that implement MessageSource

Modifier and Type	Class	Description
class	ByteStreamReadingMessageSource	A pollable source for receiving bytes from an InputStream.
class	CharacterStreamReadingMessageSource	A pollable source for Readers.

Uses of MessageSource in org.springframework.integration.test.context

Methods in org.springframework.integration.test.context with parameters of type MessageSource

Modifier and Type	Method	Description
void	MockIntegrationContext.substituteMessageSourceFor(String pollingAdapterId, MessageSource<?> mockMessageSource)	Replace the real MessageSource in the SourcePollingChannelAdapter bean with provided MessageSource instance.
void	MockIntegrationContext.substituteMessageSourceFor(String pollingAdapterId, MessageSource<?> mockMessageSource, boolean autoStartup)	Replace the real MessageSource in the SourcePollingChannelAdapter bean with provided MessageSource instance.

Uses of MessageSource in org.springframework.integration.test.mock

Methods in org.springframework.integration.test.mock that return MessageSource

Modifier and Type	Method	Description
static MessageSource<?>	MockIntegration.mockMessageSource(Message<?> message)	Build a mock for the MessageSource based on the provided message.
static MessageSource<?>	MockIntegration.mockMessageSource(Message<?> message, Message<?>... messages)	Build a mock for the MessageSource based on the provided messages.
static <T> MessageSource<T>	MockIntegration.mockMessageSource(T payload)	Build a mock for the MessageSource based on the provided payload.
static <T> MessageSource<T>	MockIntegration.mockMessageSource(T payload, T... payloads)	Build a mock for the MessageSource based on the provided payloads.

Uses of MessageSource in org.springframework.integration.util

Methods in org.springframework.integration.util with parameters of type MessageSource

Modifier and Type	Method	Description
static <T> reactor.core.publisher.Flux<Message<T>>	IntegrationReactiveUtils.messageSourceToFlux(MessageSource<T> messageSource)	Wrap a provided MessageSource into a Flux for pulling the on demand.