Uses of Interface
org.springframework.integration.core.MessageSource
Packages that use MessageSource
Package
Description
Provides classes related to message aggregation.
Provides classes supporting inbound endpoints.
Provides classes to support message publication using AOP.
Base package for configuration.
Root package of the Spring Integration Java DSL.
Provides core classes related to Endpoints.
Provides classes supporting inbound endpoints.
Base package for File support.
Provides classes for configuration - parsers, namespace handlers, factory beans.
Base package for supporting remote files.
Provides classes related to AOP.
Provides classes supporting the synchronization of remote and
local file directories.
Provides classes for configuration - parsers, namespace handlers.
Provides classes supporting inbound endpoints.
Provides classes related to the runtime object graph.
Root package of the Spring Integration JDBC module, which contains various
JDBC and Stored Procedure/Function supporting components.
Base package for JMS Support.
Base package for JMX support.
Provides inbound Spring Integration Jpa components.
Provides Spring Integration inbound components for Apache Kafka.
Base package for Mail support.
Provides classes related to the Mongo inbound channel adapters
Provides classes for supporting R2DBC inbound components.
Provides classes supporting inbound endpoints.
Provides classes related to messaging
using Spring
Resource
sBase package for scripting support.
Provides Scripting Components support for Spring Integration Java DSL.
Provides classes for configuration - parsers, namespace handlers.
Provides classes supporting inbound endpoints.
Base package for stream support.
Test context-related components.
Utilities for mocking integration components.
Provides core utility classes.
-
Uses of MessageSource in org.springframework.integration.aggregator
Classes in org.springframework.integration.aggregator that implement MessageSourceModifier and TypeClassDescriptionclass
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 -
Uses of MessageSource in org.springframework.integration.aop
Methods in org.springframework.integration.aop with parameters of type MessageSourceModifier and TypeMethodDescriptionMessage<?>
CompoundTriggerAdvice.afterReceive
(Message<?> result, MessageSource<?> source) Deprecated.Message<?>
MessageSourceMutator.afterReceive
(Message<?> result, MessageSource<?> source) Subclasses can take actions based on the result of the poll; e.g.Message<?>
SimpleActiveIdleMessageSourceAdvice.afterReceive
(Message<?> result, MessageSource<?> source) Deprecated.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 MessageSourceModifier and TypeMethodDescriptionvoid
SourcePollingChannelAdapterFactoryBean.setSource
(MessageSource<?> source) -
Uses of MessageSource in org.springframework.integration.dsl
Classes in org.springframework.integration.dsl with type parameters of type MessageSourceModifier and TypeClassDescriptionclass
MessageSourceSpec<S extends MessageSourceSpec<S,
H>, H extends MessageSource<?>> AnIntegrationComponentSpec
forMessageSource
s.Methods in org.springframework.integration.dsl with parameters of type MessageSourceModifier and TypeMethodDescriptionprotected IntegrationFlowDefinition<?>
IntegrationFlowAdapter.from
(MessageSource<?> messageSource) protected IntegrationFlowDefinition<?>
IntegrationFlowAdapter.from
(MessageSource<?> messageSource, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer) static IntegrationFlowBuilder
IntegrationFlows.from
(MessageSource<?> messageSource) Populate the providedMessageSource
object to theIntegrationFlowBuilder
chain.static IntegrationFlowBuilder
IntegrationFlows.from
(MessageSource<?> messageSource, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer) Populate the providedMessageSource
object to theIntegrationFlowBuilder
chain.Method parameters in org.springframework.integration.dsl with type arguments of type MessageSourceModifier and TypeMethodDescriptionprotected IntegrationFlowDefinition<?>
IntegrationFlowAdapter.from
(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec) protected IntegrationFlowDefinition<?>
IntegrationFlowAdapter.from
(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer) static IntegrationFlowBuilder
IntegrationFlows.from
(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec) Populate theMessageSource
object to theIntegrationFlowBuilder
chain using the fluent API from the providedMessageSourceSpec
.static IntegrationFlowBuilder
IntegrationFlows.from
(MessageSourceSpec<?, ? extends MessageSource<?>> messageSourceSpec, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer) Populate theMessageSource
object to theIntegrationFlowBuilder
chain using the fluent API from the providedMessageSourceSpec
.Constructors in org.springframework.integration.dsl with parameters of type MessageSourceModifierConstructorDescriptionprotected
SourcePollingChannelAdapterSpec
(MessageSource<?> messageSource) -
Uses of MessageSource in org.springframework.integration.endpoint
Classes in org.springframework.integration.endpoint that implement MessageSourceModifier and TypeClassDescriptionclass
A message source that can limit the number of remote objects it fetches.class
Abstract message source.class
class
TheMessageSource
strategy implementation to produce aMessage
from underlying MessageProcessorMessageSource.messageProcessor for polling endpoints.class
AMessageSource
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 MessageSourceModifier and TypeMethodDescriptionSourcePollingChannelAdapter.getMessageSource()
Return this endpoint's source.Methods in org.springframework.integration.endpoint with parameters of type MessageSourceModifier and TypeMethodDescriptionvoid
SourcePollingChannelAdapter.setSource
(MessageSource<?> source) Specify the source to be polled for Messages.Constructors in org.springframework.integration.endpoint with parameters of type MessageSourceModifierConstructorDescriptionMessageSourcePollingTemplate
(MessageSource<?> source) ReactiveMessageSourceProducer
(MessageSource<?> messageSource) Create an instance based on the providedMessageSource
. -
Uses of MessageSource in org.springframework.integration.feed.inbound
Classes in org.springframework.integration.feed.inbound that implement MessageSourceModifier and TypeClassDescriptionclass
This implementation ofMessageSource
will produce individualSyndEntry
s for a feed identified with the 'feedUrl' attribute. -
Uses of MessageSource in org.springframework.integration.file
Classes in org.springframework.integration.file that implement MessageSourceModifier and TypeClassDescriptionclass
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 MessageSourceModifier and TypeMethodDescriptionprotected abstract Class<? extends MessageSource<?>>
AbstractRemoteFileStreamingInboundChannelAdapterParser.getMessageSourceClass()
-
Uses of MessageSource in org.springframework.integration.file.remote
Classes in org.springframework.integration.file.remote that implement MessageSourceModifier and TypeClassDescriptionclass
A message source that produces a message with anInputStream
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 MessageSourceModifier and TypeMethodDescriptionMessage<?>
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 theMessageSource
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 MessageSourceModifier and TypeClassDescriptionclass
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 MessageSourceModifier and TypeMethodDescriptionprotected Class<? extends MessageSource<?>>
FtpStreamingInboundChannelAdapterParser.getMessageSourceClass()
-
Uses of MessageSource in org.springframework.integration.ftp.inbound
Classes in org.springframework.integration.ftp.inbound that implement MessageSourceModifier and TypeClassDescriptionclass
AMessageSource
implementation for FTP.class
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 MessageSourceModifierConstructorDescriptionMessageSourceNode
(int nodeId, String name, MessageSource<?> messageSource, String output, String errors) -
Uses of MessageSource in org.springframework.integration.jdbc
Classes in org.springframework.integration.jdbc that implement MessageSourceModifier and TypeClassDescriptionclass
A polling channel adapter that creates messages from the payload returned by executing a select query.class
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 MessageSourceModifier and TypeClassDescriptionclass
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 MessageSourceModifier and TypeClassDescriptionclass
AMessageSource
implementation that retrieves the current value of a JMX attribute each timeAbstractMessageSource.receive()
is invoked.class
AMessageSource
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 MessageSourceModifier and TypeClassDescriptionclass
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 MessageSourceModifier and TypeClassDescriptionclass
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 MessageSourceModifier and TypeClassDescriptionclass
MessageSource
implementation that delegates to aMailReceiver
to poll a mailbox. -
Uses of MessageSource in org.springframework.integration.mongodb.inbound
Classes in org.springframework.integration.mongodb.inbound that implement MessageSourceModifier and TypeClassDescriptionclass
AnAbstractMessageSource
extension for common MongoDB sources options and support methods.class
An instance ofMessageSource
which returns aMessage
with a payload which is the result of execution of aQuery
.class
An instance ofMessageSource
which returns aMessage
with a payload which is the result of execution of aQuery
. -
Uses of MessageSource in org.springframework.integration.r2dbc.inbound
Classes in org.springframework.integration.r2dbc.inbound that implement MessageSourceModifier and TypeClassDescriptionclass
An instance ofMessageSource
which returns aMessage
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 MessageSourceModifier and TypeClassDescriptionclass
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 MessageSourceModifier and TypeClassDescriptionclass
Implementation ofMessageSource
based onResourcePatternResolver
which will attempt to resolveResource
s based on the pattern specified. -
Uses of MessageSource in org.springframework.integration.scripting
Classes in org.springframework.integration.scripting that implement MessageSourceModifier and TypeClassDescriptionclass
TheMessageSource
strategy implementation to produce aMessage
from underlying ScriptExecutingMessageSource.scriptMessageProcessor for polling endpoints. -
Uses of MessageSource in org.springframework.integration.scripting.dsl
Methods in org.springframework.integration.scripting.dsl that return MessageSource -
Uses of MessageSource in org.springframework.integration.sftp.config
Methods in org.springframework.integration.sftp.config that return types with arguments of type MessageSourceModifier and TypeMethodDescriptionprotected Class<? extends MessageSource<?>>
SftpStreamingInboundChannelAdapterParser.getMessageSourceClass()
-
Uses of MessageSource in org.springframework.integration.sftp.inbound
Classes in org.springframework.integration.sftp.inbound that implement MessageSourceModifier and TypeClassDescriptionclass
AMessageSource
implementation for SFTP that delegates to an InboundFileSynchronizer.class
Message source for streaming SFTP remote file contents. -
Uses of MessageSource in org.springframework.integration.stream
Classes in org.springframework.integration.stream that implement MessageSourceModifier and TypeClassDescriptionclass
A pollable source for receiving bytes from anInputStream
.class
A pollable source forReaders
. -
Uses of MessageSource in org.springframework.integration.test.context
Methods in org.springframework.integration.test.context with parameters of type MessageSourceModifier and TypeMethodDescriptionvoid
MockIntegrationContext.substituteMessageSourceFor
(String pollingAdapterId, MessageSource<?> mockMessageSource) Replace the realMessageSource
in theSourcePollingChannelAdapter
bean with providedMessageSource
instance.void
MockIntegrationContext.substituteMessageSourceFor
(String pollingAdapterId, MessageSource<?> mockMessageSource, boolean autoStartup) Replace the realMessageSource
in theSourcePollingChannelAdapter
bean with providedMessageSource
instance. -
Uses of MessageSource in org.springframework.integration.test.mock
Methods in org.springframework.integration.test.mock that return MessageSourceModifier and TypeMethodDescriptionstatic MessageSource<?>
MockIntegration.mockMessageSource
(Message<?> message) Build a mock for theMessageSource
based on the provided message.static MessageSource<?>
MockIntegration.mockMessageSource
(Message<?> message, Message<?>... messages) Build a mock for theMessageSource
based on the provided messages.static <T> MessageSource<T>
MockIntegration.mockMessageSource
(T payload) Build a mock for theMessageSource
based on the provided payload.static <T> MessageSource<T>
MockIntegration.mockMessageSource
(T payload, T... payloads) Build a mock for theMessageSource
based on the provided payloads. -
Uses of MessageSource in org.springframework.integration.util
Methods in org.springframework.integration.util with parameters of type MessageSourceModifier and TypeMethodDescriptionstatic <T> reactor.core.publisher.Flux<Message<T>>
IntegrationReactiveUtils.messageSourceToFlux
(MessageSource<T> messageSource) Wrap a providedMessageSource
into aFlux
for pulling the on demand.
CompoundTriggerAdvice.afterReceive(Message, Object)