All Classes
| Class | Description |
|---|---|
| AbstractAggregatingMessageGroupProcessor |
Base class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message.
|
| AbstractAmqpChannel | |
| AbstractAmqpOutboundEndpoint | |
| AbstractAmqpOutboundEndpoint.CorrelationDataWrapper | |
| AbstractBatchingMessageGroupStore | |
| AbstractByteArraySerializer |
Base class for (de)serializers that provide a mechanism to
reconstruct a byte array from an arbitrary stream.
|
| AbstractCandidate |
Base implementation of a
Candidate. |
| AbstractChannelAdapterParser |
Base parser for Channel Adapters.
|
| AbstractChannelMessageStoreQueryProvider | |
| AbstractChannelParser |
Base class for channel parsers.
|
| AbstractClientConnectionFactory |
Abstract class for client connection factories; client connection factories
establish outgoing connections.
|
| AbstractConfigurableMongoDbMessageStore |
The abstract MongoDB
AbstractMessageGroupStore implementation to provide configuration for common options
for implementations of this class. |
| AbstractConnectionFactory |
Base class for all connection factories.
|
| AbstractConnectionFactorySpec<S extends AbstractConnectionFactorySpec<S,C>,C extends AbstractConnectionFactory> | |
| AbstractConsumerEndpointParser |
Base class parser for elements that create Message Endpoints.
|
| AbstractCorrelatingMessageHandler |
Abstract Message handler that holds a buffer of correlated messages in a
MessageStore. |
| AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup | |
| AbstractCorrelatingMessageHandlerParser |
Base class for parsers that create an instance of
AbstractCorrelatingMessageHandler. |
| AbstractDirectoryAwareFileListFilter<F> |
A file list filter that can be configured to always accept (pass) directories.
|
| AbstractDispatcher |
Base class for
MessageDispatcher implementations. |
| AbstractEndpoint |
The base class for Message Endpoint implementations.
|
| AbstractEvaluationContextFactoryBean |
Abstract class for integration evaluation context factory beans.
|
| AbstractExecutorChannel |
The
AbstractSubscribableChannel base implementation for those inheritors
which logic may be based on the Executor. |
| AbstractExpressionEvaluator | |
| AbstractFetchLimitingMessageSource<T> |
A message source that can limit the number of remote objects it fetches.
|
| AbstractFileInfo<F> |
Abstract implementation of
FileInfo; provides a setter
for the remote directory and a generic toString implementation. |
| AbstractFileListFilter<F> |
A convenience base class for any
FileListFilter whose criteria can be
evaluated against each File in isolation. |
| AbstractFileLockerFilter |
Convenience base class for implementing FileLockers that check a lock before accepting a file.
|
| AbstractFilePayloadTransformer<T> |
Base class for transformers that convert a File payload.
|
| AbstractFilePayloadTransformerParser |
Base class for File payload transformer parsers.
|
| AbstractFtpSessionFactory<T extends org.apache.commons.net.ftp.FTPClient> |
Base class for FTP SessionFactory implementations.
|
| AbstractHandleMessageAdvice |
The base
HandleMessageAdvice for advices which can be applied only
for the MessageHandler.handleMessage(Message). |
| AbstractHeaderMapper<T> |
Abstract base class for
RequestReplyHeaderMapper implementations. |
| AbstractHeaderMapper.CompositeHeaderMatcher |
A composite
AbstractHeaderMapper.HeaderMatcher that matches if one of provided
AbstractHeaderMapper.HeaderMatchers matches to the headerName. |
| AbstractHeaderMapper.ContentBasedHeaderMatcher |
A content-based
AbstractHeaderMapper.HeaderMatcher that matches if the specified
header is contained within a list of candidates. |
| AbstractHeaderMapper.HeaderMatcher |
Strategy interface to determine if a given header name matches.
|
| AbstractHeaderMapper.PatternBasedHeaderMatcher |
A pattern-based
AbstractHeaderMapper.HeaderMatcher that matches if the specified
header matches one of the specified simple patterns. |
| AbstractHeaderMapper.PrefixBasedMatcher |
A prefix-based
AbstractHeaderMapper.HeaderMatcher that matches if the specified
header starts with a configurable prefix. |
| AbstractHeaderMapper.SinglePatternBasedHeaderMatcher |
A pattern-based
AbstractHeaderMapper.HeaderMatcher that matches if the specified
header matches the specified simple pattern. |
| AbstractHeaderValueMessageProcessor<T> | |
| AbstractHttpRequestExecutingMessageHandler |
Base class for http outbound adapter/gateway.
|
| AbstractInboundFileSynchronizer<F> |
Base class charged with knowing how to connect to a remote file system,
scan it for new files and then download the files.
|
| AbstractInboundFileSynchronizingMessageSource<F> |
Factors out the common logic between the FTP and SFTP adapters.
|
| AbstractInboundGatewayParser |
Base class for inbound gateway parsers.
|
| AbstractIntegrationMessageBuilder<T> | |
| AbstractIntegrationNamespaceHandler |
Base class for NamespaceHandlers that registers a BeanFactoryPostProcessor
for configuring default bean definitions.
|
| AbstractInternetProtocolReceivingChannelAdapter |
Base class for inbound TCP/UDP Channel Adapters.
|
| AbstractInternetProtocolSendingMessageHandler |
Base class for UDP MessageHandlers.
|
| AbstractJacksonJsonObjectMapper<N,P,J> |
Base class for Jackson
JsonObjectMapper implementations. |
| AbstractJmsChannel | |
| AbstractJpaOutboundGatewayParser |
The Abstract Parser for the JPA Outbound Gateways.
|
| AbstractJsonInboundMessageMapper<P> |
Abstract
InboundMessageMapper implementation that maps incoming JSON messages
to a Message with the specified payload type. |
| AbstractKafkaChannel |
Abstract MessageChannel backed by a Kafka topic.
|
| AbstractKafkaChannelSpec<S extends AbstractKafkaChannelSpec<S,C>,C extends AbstractKafkaChannel> |
Spec for a message channel backed by a Kafka topic.
|
| AbstractKeyValueMessageStore |
Base class for implementations of Key/Value style
MessageGroupStore and MessageStore |
| AbstractKryoCodec |
Base class for
Codecs using Kryo. |
| AbstractKryoRegistrar |
Base class for
KryoRegistrar implementations. |
| AbstractLeaderEvent |
Base
ApplicationEvent class for leader based events. |
| AbstractMailMessageTransformer<T> |
Base class for Transformers that convert from a JavaMail Message to a
Spring Integration Message.
|
| AbstractMailReceiver |
Base class for
MailReceiver implementations. |
| AbstractMappingMessageRouter |
Base class for all Message Routers that support mapping from arbitrary String values
to Message Channel names.
|
| AbstractMarkerFilePresentFileListFilter<F> |
A FileListFilter that only passes files matched by one or more
FileListFilter
if a corresponding marker file is also present to indicate a file transfer is complete. |
| AbstractMessageChannel |
Base class for
MessageChannel implementations providing common
properties such as the channel name. |
| AbstractMessageChannel.ChannelInterceptorList |
A convenience wrapper class for the list of ChannelInterceptors.
|
| AbstractMessageGroupStore | |
| AbstractMessageHandler |
Base class for
MessageHandler implementations. |
| AbstractMessageListenerContainerSpec<S extends AbstractMessageListenerContainerSpec<S,C>,C extends AbstractMessageListenerContainer> |
Base class for container specs.
|
| AbstractMessageProcessingSelector |
A base class for
MessageSelector implementations that delegate to
a MessageProcessor. |
| AbstractMessageProcessingTransformer |
Base class for Message Transformers that delegate to a
MessageProcessor. |
| AbstractMessageProcessor<T> | |
| AbstractMessageProducingHandler |
The base
AbstractMessageHandler implementation for the MessageProducer. |
| AbstractMessageRouter |
Base class for all Message Routers.
|
| AbstractMessageSource<T> |
Abstract message source.
|
| AbstractMessageSourceAdvice | Deprecated.
since 5.3 in favor of
MessageSourceMutator. |
| AbstractMessageSplitter |
Base class for Message-splitting handlers.
|
| AbstractMethodAnnotationPostProcessor<T extends Annotation> |
Base class for Method-level annotation post-processors.
|
| AbstractMqttMessageDrivenChannelAdapter |
Abstract class for MQTT Message-Driven Channel Adapters.
|
| AbstractMqttMessageHandler |
Abstract class for MQTT outbound channel adapters.
|
| AbstractOutboundChannelAdapterParser |
Base class for outbound Channel Adapter parsers.
|
| AbstractOutboundGatewayParser |
Base class for url-based outbound gateway parsers.
|
| AbstractPayloadTransformer<T,U> |
A base class for
Transformer implementations that modify the payload
of a Message. |
| AbstractPersistentAcceptOnceFileListFilter<F> |
Stores "seen" files in a MetadataStore to survive application restarts.
|
| AbstractPollableChannel |
Base class for all pollable channels.
|
| AbstractPollingEndpoint | |
| AbstractPollingInboundChannelAdapterParser |
Base parser for inbound Channel Adapters that poll a source.
|
| AbstractPooledBufferByteArraySerializer |
Base class for deserializers that cannot determine the buffer size needed.
|
| AbstractReactiveMessageHandler |
Base class for
ReactiveMessageHandler implementations. |
| AbstractRegexPatternFileListFilter<F> |
Filters a listing of files by qualifying their 'name'
against a regular expression (an instance of
Pattern) |
| AbstractRemoteFileInboundChannelAdapterParser |
Abstract base class for parsing remote file inbound channel adapters.
|
| AbstractRemoteFileOutboundGateway<F> |
Base class for Outbound Gateways that perform remote file operations.
|
| AbstractRemoteFileOutboundGateway.Command |
Enumeration of commands supported by the gateways.
|
| AbstractRemoteFileOutboundGateway.Option |
Enumeration of options supported by various commands.
|
| AbstractRemoteFileOutboundGatewayParser | |
| AbstractRemoteFileStreamingInboundChannelAdapterParser |
Abstract base class for parsing remote file streaming inbound channel adapters.
|
| AbstractRemoteFileStreamingMessageSource<F> |
A message source that produces a message with an
InputStream payload
referencing a remote file. |
| AbstractReplyProducingMessageHandler |
Base class for MessageHandlers that are capable of producing replies.
|
| AbstractReplyProducingMessageHandler.RequestHandler |
An implementation of this interface is used to wrap the
AbstractReplyProducingMessageHandler.handleRequestMessage(Message)
method. |
| AbstractReplyProducingPostProcessingMessageHandler | |
| AbstractRequestHandlerAdvice |
Base class for
MessageHandler advice classes. |
| AbstractRequestHandlerAdvice.ExecutionCallback |
Called by subclasses in doInvoke() to proceed() the invocation.
|
| AbstractRequestHandlerAdvice.ThrowableHolderException | |
| AbstractRequestResponseScenarioTests |
Convenience class for testing Spring Integration request-response message scenarios.
|
| AbstractResponseValidator<T> |
The base class for response validators used for
RequestResponseScenarios |
| AbstractRouterParser |
Base parser for routers.
|
| AbstractRouterSpec<S extends AbstractRouterSpec<S,R>,R extends AbstractMessageRouter> | |
| AbstractRSocketConnector |
A base connector container for common RSocket client and server functionality.
|
| AbstractScriptExecutingMessageProcessor<T> |
Base
MessageProcessor for scripting implementations to extend. |
| AbstractScriptExecutor |
Base Class for
ScriptExecutor. |
| AbstractScriptParser | |
| AbstractServerConnectionFactory |
Base class for all server connection factories.
|
| AbstractSimpleMessageHandlerFactoryBean<H extends MessageHandler> |
Factory bean to create and configure a
MessageHandler. |
| AbstractSimplePatternFileListFilter<F> |
Base class for filters that support ant style path expressions, which are less powerful
but more readable than regular expressions.
|
| AbstractStandardMessageHandlerFactoryBean |
Base class for FactoryBeans that create standard MessageHandler instances.
|
| AbstractStompSessionManager |
Base
StompSessionManager implementation to manage a single StompSession
over its ListenableFuture from the target implementation of this class. |
| AbstractSubscribableChannel |
Base implementation of
MessageChannel that
invokes the subscribed handler(s) by delegating to a
MessageDispatcher. |
| AbstractTcpConnectionSupport |
Base class for TCP Connection Support implementations.
|
| AbstractTransformer |
A base class for
Transformer implementations. |
| AbstractTransformerParser | |
| AbstractUdpOutboundChannelAdapterSpec<S extends AbstractUdpOutboundChannelAdapterSpec<S>> |
A
MessageHandlerSpec for UDP MessageHandlers. |
| AbstractWebServiceInboundGateway | |
| AbstractWebServiceOutboundGateway |
Base class for outbound Web Service-invoking Messaging Gateways.
|
| AbstractXmlTransformer |
super class for XmlTransformer
|
| AbstractXmppConnectionAwareEndpoint | |
| AbstractXmppConnectionAwareMessageHandler | |
| AbstractXmppInboundChannelAdapterParser |
Base class for XMPP inbound parsers
|
| AbstractXmppOutboundChannelAdapterParser |
Base class of XMPP outbound parsers
|
| AbstractXPathMessageSelector |
Base class for XPath
MessageSelector implementations. |
| AcceptAllFileListFilter<F> |
Simple implementation of
FileListFilter that always returns true. |
| AcceptOnceCollectionFilter<T> |
An implementation of
CollectionFilter that remembers the elements passed in
the previous invocation in order to avoid returning those elements more than once. |
| AcceptOnceFileListFilter<F> |
FileListFilter that passes files only one time. |
| AcknowledgmentCallback |
A general abstraction over acknowledgments.
|
| AcknowledgmentCallback.Status | |
| AcknowledgmentCallbackFactory<T> |
A factory for creating
AcknowledgmentCallbacks. |
| AckUtils |
Utility methods for acting on
AcknowledgmentCallback headers. |
| AdviceMessage<T> |
A message implementation that is produced by an advice after
successful message handling.
|
| AdviceMessageJacksonDeserializer |
The
MessageJacksonDeserializer implementation for the AdviceMessage. |
| AggregatedXmlMessageValidationException | |
| AggregateMessageDeliveryException |
An Exception that encapsulates an aggregated group of Exceptions for use by dispatchers
that may try multiple handler invocations within a single dispatch operation.
|
| AggregatingMessageHandler |
Aggregator specific implementation of
AbstractCorrelatingMessageHandler. |
| Aggregator |
Indicates that a method is capable of aggregating messages.
|
| AggregatorAnnotationPostProcessor |
Post-processor for the
@Aggregator annotation. |
| AggregatorFactoryBean |
FactoryBean to create an
AggregatingMessageHandler. |
| AggregatorParser |
Parser for the aggregator element of the integration namespace.
|
| AggregatorSpec | |
| AllowListDeserializingConverter |
A
Converter that delegates to a
Deserializer to convert data in a byte
array to an object. |
| Amqp |
Factory class for AMQP components.
|
| AmqpAsyncOutboundGatewaySpec | |
| AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>> |
The base
MessageProducerSpec implementation for a AmqpInboundChannelAdapter. |
| AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>> |
A base
MessagingGatewaySpec implementation for AmqpInboundGateway endpoint options. |
| AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends AbstractAmqpOutboundEndpoint> |
The base
MessageHandlerSpec for AbstractAmqpOutboundEndpoints. |
| AmqpChannelFactoryBean |
If point-to-point, we send to the default exchange with the routing key
equal to "[beanName]" and we declare that same Queue and register a listener
if message-driven or poll explicitly otherwise.
|
| AmqpChannelParser |
Parser for the 'channel' and 'publish-subscribe-channel' elements of the
Spring Integration AMQP namespace.
|
| AmqpHeaderMapper |
A convenience interface that extends
RequestReplyHeaderMapper,
parameterized with MessageProperties. |
| AmqpInboundChannelAdapter |
Adapter that receives Messages from an AMQP Queue, converts them into
Spring Integration Messages, and sends the results to a Message Channel.
|
| AmqpInboundChannelAdapter.BatchMode |
Defines the payload type when the listener container is configured with consumerBatchEnabled.
|
| AmqpInboundChannelAdapterDMLCSpec |
Spec for an inbound channel adapter with a
DirectMessageListenerContainer. |
| AmqpInboundChannelAdapterParser |
Parser for the AMQP 'inbound-channel-adapter' element.
|
| AmqpInboundChannelAdapterSMLCSpec |
Spec for an inbound channel adapter with a
SimpleMessageListenerContainer. |
| AmqpInboundChannelAdapterSpec<S extends AmqpInboundChannelAdapterSpec<S,C>,C extends AbstractMessageListenerContainer> | |
| AmqpInboundGateway |
Adapter that receives Messages from an AMQP Queue, converts them into
Spring Integration Messages, and sends the results to a Message Channel.
|
| AmqpInboundGatewayDMLCSpec |
Spec for a gateway with a
DirectMessageListenerContainer. |
| AmqpInboundGatewayParser |
Parser for the AMQP 'inbound-gateway' element.
|
| AmqpInboundGatewaySMLCSpec |
Spec for a gateway with a
SimpleMessageListenerContainer. |
| AmqpInboundGatewaySpec<S extends AmqpInboundGatewaySpec<S,C>,C extends AbstractMessageListenerContainer> |
An
AmqpBaseInboundGatewaySpec implementation for a AmqpInboundGateway. |
| AmqpInboundPolledChannelAdapterSpec |
Spec for a polled AMQP inbound channel adapter.
|
| AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> |
An
AmqpPollableMessageChannelSpec for a message-driven
PointToPointSubscribableAmqpChannel. |
| AmqpMessageHeaderErrorMessageStrategy |
An
ErrorMessageStrategy extension that adds the raw AMQP message as
a header to the ErrorMessage. |
| AmqpMessageSource |
A pollable
MessageSource for RabbitMQ. |
| AmqpMessageSource.AmqpAckCallback | |
| AmqpMessageSource.AmqpAckCallbackFactory | |
| AmqpMessageSource.AmqpAckInfo |
Information for building an AmqpAckCallback.
|
| AmqpNamespaceHandler |
Namespace handler for the AMQP schema.
|
| AmqpOutboundChannelAdapterParser |
Parser for the AMQP 'outbound-channel-adapter' element.
|
| AmqpOutboundChannelAdapterSpec |
Spec for an outbound AMQP channel adapter
|
| AmqpOutboundEndpoint |
Adapter that converts and sends Messages to an AMQP Exchange.
|
| AmqpOutboundEndpointSpec<S extends AmqpOutboundEndpointSpec<S>> |
Base spec for outbound AMQP endpoints.
|
| AmqpOutboundGatewayParser |
Parser for the AMQP 'outbound-channel-adapter' element.
|
| AmqpOutboundGatewaySpec |
Spec for an outbound AMQP gateway.
|
| AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> |
A
MessageChannelSpec for a AbstractAmqpChannels. |
| AmqpPublishSubscribeMessageChannelSpec | |
| AnnotatedMethodFilter |
A MethodFilter implementation that enables the following:
matching on method name, if available
exclusion of void-returning methods if 'requiresReply' is true
limiting to annotated methods if at least one is present
|
| AnnotationConfigParser |
Parser for the <annotation-config> element of the integration namespace.
|
| AnnotationConstants |
Common value constants for annotation attributes.
|
| AnnotationGatewayProxyFactoryBean |
A
GatewayProxyFactoryBean extension for Java configuration. |
| AnnotationMetadataAdapter |
An
AnnotationMetadata implementation to expose a metadata
by the provided Map of attributes. |
| ApacheCommonsFileTailingMessageProducer |
File tailer that delegates to the Apache Commons Tailer.
|
| ApacheMinaFtpEvent |
ApplicationEvent generated from Apache Mina ftp events. |
| ApacheMinaFtplet |
A listener for FTP events emitted by an Apache Mina ftp server.
|
| ApacheMinaSftpEvent |
ApplicationEvent generated from Apache Mina sftp events. |
| ApacheMinaSftpEventListener |
A listener for SFTP events emitted by an Apache Mina sshd/sftp server.
|
| ApplicationEventListeningMessageProducer |
An inbound Channel Adapter that implements
GenericApplicationListener and
passes Spring ApplicationEvents within messages. |
| ApplicationEventMulticasterParser |
Parser for the <application-event-multicaster> element of the
integration namespace.
|
| ApplicationEventPublishingMessageHandler | |
| ArgumentsStrategy | |
| AsyncAmqpOutboundGateway |
An outbound gateway where the sending thread is released immediately and the reply
is sent on the async template's listener container thread.
|
| AsyncMessagingOperations | |
| AsyncMessagingTemplate | |
| AttributePollingChannelAdapterParser | |
| AttributePollingMessageSource |
A
MessageSource implementation that
retrieves the current value of a JMX attribute each time AbstractMessageSource.receive() is invoked. |
| AvroHeaders |
Pre-defined names and prefixes for Apache Avro related headers.
|
| BarrierMessageHandler |
A message handler that suspends the thread until a message with corresponding
correlation is passed into the
trigger method or
the timeout occurs. |
| BarrierParser |
Parser for
<int:barrier/>. |
| BarrierSpec |
A
MessageHandlerSpec for the BarrierMessageHandler. |
| BaseHttpInboundEndpoint |
The
MessagingGatewaySupport extension for HTTP Inbound endpoints
with basic properties. |
| BaseHttpInboundEndpointSpec<S extends BaseHttpInboundEndpointSpec<S,E>,E extends HttpRequestHandlingEndpointSupport> |
A base
MessagingGatewaySpec for the
HttpRequestHandlingEndpointSupport implementations. |
| BaseHttpMessageHandlerSpec<S extends BaseHttpMessageHandlerSpec<S,E>,E extends AbstractHttpRequestExecutingMessageHandler> |
The base
MessageHandlerSpec for AbstractHttpRequestExecutingMessageHandlers. |
| BaseIntegrationFlowDefinition<B extends BaseIntegrationFlowDefinition<B>> |
The
Builder pattern implementation for the EIP-method chain. |
| BaseIntegrationFlowDefinition.ReplyProducerCleaner | |
| BaseWsInboundGatewaySpec<S extends BaseWsInboundGatewaySpec<S,E>,E extends AbstractWebServiceInboundGateway> |
Base
MessagingGatewaySpec for web services. |
| BaseWsOutboundGatewaySpec<S extends BaseWsOutboundGatewaySpec<S,E>,E extends AbstractWebServiceOutboundGateway> |
The base
MessageHandlerSpec for AbstractWebServiceOutboundGateways. |
| BasicMessageGroupStore |
Defines a minimal message group store with basic capabilities.
|
| BeanDefinitionRegisteringParser |
Simple strategy interface for parsers that are responsible
for parsing an element, creating a bean definition, and then
registering the bean.
|
| BeanFactoryChannelResolver |
DestinationResolver implementation based on a Spring BeanFactory. |
| BeanFactoryTypeConverter | |
| BeanNameMessageProcessor<T> |
An "artificial"
MessageProcessor for lazy-load of target bean by its name. |
| BeanPropertyParameterSource | |
| BeanPropertyParameterSourceFactory | |
| BeanPropertySqlParameterSourceFactory |
A default implementation of
SqlParameterSourceFactory which creates an SqlParameterSource to
reference bean properties in its input. |
| BinaryToMessageConverter | |
| BooleanTestXPathMessageSelector |
Boolean XPath testing
MessageSelector. |
| BoundRabbitChannelAdvice |
An advice that causes all downstream
RabbitOperations operations to be executed
on the same channel, as long as there are no thread handoffs, since the channel is
bound to the thread. |
| BridgeFrom |
Messaging Annotation to mark a
Bean
method for a MessageChannel to produce a
BridgeHandler and Consumer Endpoint. |
| BridgeFromAnnotationPostProcessor |
Post-processor for the
@BridgeFrom annotation. |
| BridgeHandler |
A simple MessageHandler implementation that passes the request Message
directly to the output channel without modifying it.
|
| BridgeParser |
Parser for the <bridge> element.
|
| BridgeTo |
Messaging Annotation to mark a
Bean
method for a MessageChannel to produce a
BridgeHandler and Consumer Endpoint. |
| BridgeToAnnotationPostProcessor |
Post-processor for the
@BridgeTo annotation. |
| BroadcastCapableChannel |
A
SubscribableChannel variant for implementations with broadcasting capabilities. |
| BroadcastingDispatcher |
A broadcasting dispatcher implementation.
|
| BroadcastPublishSubscribeSpec |
An
IntegrationComponentSpec for configuring sub-flow subscribers on the
provided BroadcastCapableChannel. |
| ByteArrayCrLfSerializer |
Reads data in an InputStream to a byte[]; data must be terminated by \r\n
(not included in resulting byte[]).
|
| ByteArrayElasticRawDeserializer |
A deserializer that uses a
ByteArrayOutputStream instead of a fixed buffer,
allowing the buffer to grow as needed. |
| ByteArrayLengthHeaderSerializer |
Reads data in an InputStream to a byte[]; data must be preceded by
a binary length (network byte order, not included in resulting byte[]).
|
| ByteArrayLfSerializer | |
| ByteArrayRawSerializer |
A byte array (de)serializer that does nothing with the payload; sends it raw.
|
| ByteArraySingleTerminatorSerializer |
Reads data in an InputStream to a byte[]; data must be terminated by a single
byte (not included in resulting byte[]).
|
| ByteArrayStxEtxSerializer |
Reads data in an InputStream to a byte[]; data must be prefixed by <stx> and
terminated by <etx> (not included in resulting byte[]).
|
| BytesMessageMapper | |
| ByteStreamReadingMessageSource |
A pollable source for receiving bytes from an
InputStream. |
| ByteStreamWritingMessageHandler |
A
MessageHandler that writes a byte array to an
OutputStream. |
| CacheListeningMessageProducer |
An inbound endpoint that listens to a GemFire region for events and then publishes Messages to
a channel.
|
| CacheRequestHandlerAdvice |
The
AbstractRequestHandlerAdvice implementation for caching
AbstractReplyProducingMessageHandler.RequestHandler#handleRequestMessage(Message) results. |
| CacheWritingMessageHandler |
A
MessageHandler implementation that writes to a
GemFire Region. |
| CachingClientConnectionFactory |
Connection factory that caches connections from the underlying target factory.
|
| CachingSessionFactory<F> |
A
SessionFactory implementation that caches Sessions for reuse without
requiring reconnection each time the Session is retrieved from the factory. |
| CallerBlocksPolicy |
A
RejectedExecutionHandler that blocks the caller until
the executor has room in its queue, or a timeout occurs (in which
case a RejectedExecutionException is thrown. |
| Candidate |
Interface that defines the contract for candidates to participate
in a leader election.
|
| ChainFileListFilter<F> |
The
CompositeFileListFilter extension which chains the result
of the previous filter to the next one. |
| ChainParser |
Parser for the <chain> element.
|
| ChannelAccessPolicy |
Interface to encapsulate
ConfigAttributes for secured channel
send and receive operations. |
| ChannelInterceptorParser |
A helper class for parsing the sub-elements of a channel's
interceptors element.
|
| ChannelInvocation |
Secured object for
ChannelSecurityInterceptor. |
| ChannelMessageStore |
A marker interface that indicates this message store has optimizations for
use in a
QueueChannel. |
| ChannelMessageStorePreparedStatementSetter |
Callback to be used with the
JdbcChannelMessageStore. |
| ChannelMessageStoreQueryProvider |
Common interface used in order to configure the
JdbcChannelMessageStore to provide
database-specific queries. |
| ChannelPublishingJmsMessageListener |
JMS MessageListener that converts a JMS Message into a Spring Integration
Message and sends that Message to a channel.
|
| ChannelPurger |
A utility class for purging
Messages from one or more
QueueChannels. |
| ChannelResolverUtils |
Channel resolution utilities.
|
| Channels | |
| ChannelSecurityInterceptor |
An AOP interceptor that enforces authorization for MessageChannel send and/or receive calls.
|
| ChannelSecurityInterceptorBeanPostProcessor | |
| ChannelSecurityMetadataSource |
The
SecurityMetadataSource implementation for secured MessageChannels. |
| ChannelUtils |
Channel utilities.
|
| CharacterStreamReadingMessageSource |
A pollable source for
Readers. |
| CharacterStreamWritingMessageHandler |
A
MessageHandler
that writes characters to a Writer. |
| ChatMessageInboundChannelAdapterParser |
Parser for the XMPP 'inbound-channel-adapter' element.
|
| ChatMessageListeningEndpoint |
This component logs in as a user and forwards any messages to that
user on to downstream components.
|
| ChatMessageOutboundChannelAdapterParser |
Parser for the XMPP 'outbound-channel-adapter' element
|
| ChatMessageSendingMessageHandler |
MessageHandler that sends an XMPP Chat Message.
|
| ClaimCheckInParser |
Parser for the <claim-check-in/> element.
|
| ClaimCheckInTransformer |
Transformer that stores a Message and returns a new Message whose payload
is the id of the stored Message.
|
| ClaimCheckOutParser |
Parser for the <claim-check-out/> element.
|
| ClaimCheckOutTransformer |
Transformer that accepts a Message whose payload is a UUID and retrieves the Message associated
with that id from a MessageStore if available.
|
| ClassUtils | |
| ClientCallback<C,T> |
RemoteFileTemplate callback with the underlying client instance providing
access to lower level methods. |
| ClientCallbackWithoutResult<C> |
RemoteFileTemplate callback with the underlying client instance providing
access to lower level methods where no result is returned. |
| ClientHttpResponseBodyExtractor |
The
BodyExtractor identity function implementation
which just returns the provided ClientHttpResponse. |
| ClientModeCapable |
Edpoints implementing this interface are capable
of running in client-mode.
|
| ClientModeConnectionManager |
Intended to be run on a schedule, simply gets the connection
from a client connection factory each time it is run.
|
| ClientRSocketConnector |
A client
AbstractRSocketConnector extension to the RSocket connection. |
| ClientStompEncoder |
A
StompEncoder extension to prepare a message for sending/receiving
before/after encoding/decoding when used from WebSockets client side. |
| ClientWebSocketContainer |
The
IntegrationWebSocketContainer implementation for the client
Web-Socket connection. |
| ClientWebSocketContainerParser |
The
AbstractSingleBeanDefinitionParser implementation for
the <websocket:client-container/> element. |
| CloseableIterator<E> |
A
CloseableIterator is intended to be used when it may hold resources (such as file or socket handles). |
| Codec |
Interface for classes that perform both encode (serialize) and decode (deserialize) on multiple classes.
|
| CodecMessageConverter |
A
MessageConverter that delegates to a Codec to convert |
| CollectionArgumentResolver | |
| CollectionFilter<T> |
Base strategy for filtering out a subset of a Collection of elements.
|
| CommonSocketOptions | |
| ComponentsRegistration |
The marker interface for the
IntegrationComponentSpec implementation,
when there is need to register as beans not only the target spec's components,
but some additional components, e.g. |
| CompositeCodec |
A Codec that can delegate to one out of many Codecs, each mapped to a class.
|
| CompositeExecutor |
An
Executor that encapsulates two underlying executors. |
| CompositeFileListFilter<F> |
Simple
FileListFilter that predicates its matches against all of the
configured FileListFilter. |
| CompositeKryoRegistrar |
A
KryoRegistrar that delegates and validates registrations across all components. |
| CompositeMessageHandler |
Classes implementing this interface delegate to a list of handlers.
|
| CompositeMessageHandlerNode |
Represents a composite message handler.
|
| CompositeMessageHandlerNode.InnerHandler | |
| CompoundTrigger |
A
Trigger that delegates the CompoundTrigger.nextExecutionTime(TriggerContext)
to one of two Triggers. |
| CompoundTriggerAdvice |
A
MessageSourceMutator that uses a CompoundTrigger to adjust
the poller - when a message is present, the compound trigger's primary trigger is
used to determine the next poll. |
| ConcurrentMetadataStore |
Supports atomic updates to values in the store.
|
| ConfigurableCompositeMessageConverter |
A
CompositeMessageConverter extension with some default MessageConverters
which can be overridden with the given converters
or added in the end of target converters collection. |
| ConfigurableMongoDbMessageStore |
An alternate MongoDB
MessageStore and
MessageGroupStore which allows the user to
configure the instance of MongoTemplate. |
| ConnectionFactory |
A factory used to create TcpConnection objects.
|
| ConsoleInboundChannelAdapterParser |
Parser for the <stdin-channel-adapter> element.
|
| ConsoleOutboundChannelAdapterParser |
Parser for the "stdout-" and "stderr-channel-adapter" elements.
|
| ConsumerEndpointFactoryBean |
The
FactoryBean implementation for AbstractEndpoint population. |
| ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends MessageHandler> |
A
EndpointSpec for consumer endpoints. |
| ConsumerStopAction |
Action to take regarding subscrptions when consumer stops.
|
| ContentEnricher |
Content Enricher is a Message Transformer that can augment a message's payload with
either static values or by optionally invoking a downstream message flow via its
request channel and then applying values from the reply Message to the original
payload.
|
| Context |
Interface that defines the context for candidate leadership.
|
| ContinuousQueryMessageProducer |
Responds to a Gemfire continuous query (set using the #query field) that is
constantly evaluated against a cache
Region. |
| ControlBusMethodFilter |
SpEL
MethodFilter to restrict method invocations to:
Pausable or Lifecycle components
get, set and shutdown methods of CustomizableThreadCreator
methods with ManagedAttribute and ManagedOperation annotations
This class isn't designed for target applications and typically is used from ExpressionControlBusFactoryBean. |
| ControlBusParser | |
| ConverterParser | |
| ConvertingBytesMessageMapper |
The
BytesMessageMapper implementation to delegate to/from Message
conversion into the provided MessageConverter. |
| CorrelatingMessageBarrier |
This Endpoint serves as a barrier for messages that should not be processed yet.
|
| CorrelationHandlerSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler> | |
| CorrelationStrategy |
Strategy for determining how messages can be correlated.
|
| CorrelationStrategy |
Indicates that a given method is capable of determining the correlation key
of a message sent as parameter.
|
| CorrelationStrategyFactoryBean |
Convenience factory for XML configuration of a
CorrelationStrategy. |
| CounterFacade | |
| CqEventType |
Enumeration of GemFire Continuous Query Event Types
|
| CrossOrigin |
The mapping to permit cross origin requests (CORS) for
HttpRequestHandlingEndpointSupport. |
| CuratorFrameworkFactoryBean |
A Spring-friendly way to build a
CuratorFramework and implementing SmartLifecycle. |
| DatagramPacketMessageMapper |
Message Mapper for converting to and from UDP DatagramPackets.
|
| DecodingTransformer<T> |
AbstractPayloadTransformer that delegates to a codec to decode the
payload from a byte[]. |
| Default |
Indicates that the class member has some default meaning.
|
| DefaultAggregateHeadersFunction |
The
Function implementation for a default headers merging in the aggregator
component. |
| DefaultAggregatingMessageGroupProcessor |
This implementation of MessageGroupProcessor will take the messages from the
MessageGroup and pass them on in a single message with a Collection as a payload.
|
| DefaultAmqpHeaderMapper |
Default implementation of
AmqpHeaderMapper. |
| DefaultCandidate |
Simple
Candidate for leadership. |
| DefaultChannelAccessPolicy |
Creates the
ConfigAttributes for secured channel
send and receive operations based on simple String values. |
| DefaultDatatypeChannelMessageConverter |
Default message converter for datatype channels.
|
| DefaultDirectoryScanner |
Default directory scanner and base class for other directory scanners.
|
| DefaultErrorMessageStrategy |
A simple
ErrorMessageStrategy implementations which produces
a error message with original message if the AttributeAccessor has
ErrorMessageUtils.INPUT_MESSAGE_CONTEXT_KEY attribute. |
| DefaultFileNameGenerator |
Default implementation of the filename generator strategy.
|
| DefaultFtpSessionFactory |
Default implementation of FTP SessionFactory.
|
| DefaultFtpsSessionFactory |
SessionFactory for FTPS.
|
| DefaultHeaderChannelRegistry |
Converts a channel to a name, retaining a reference to the channel keyed by the name.
|
| DefaultHttpHeaderMapper |
Default
HeaderMapper implementation for HTTP. |
| DefaultInboundChannelAdapterParser |
Parser for the <inbound-channel-adapter/> element.
|
| DefaultJmsHeaderMapper |
Default implementation of
JmsHeaderMapper. |
| DefaultJpaOperations |
Class similar to JPA template limited to the operations required for the JPA adapters/gateway
not using JpaTemplate as the class is deprecated since Spring 3.1.
|
| DefaultLeaderEventPublisher |
Default implementation of
LeaderEventPublisher. |
| DefaultLockRegistry |
Default implementation of
LockRegistry which uses Masked Hashcode algorithm to obtain locks. |
| DefaultLockRepository |
The default implementation of the
LockRepository based on the
table from the script presented in the org/springframework/integration/jdbc/schema-*.sql. |
| DefaultMailHeaderMapper |
Maps an inbound
MimeMessage to a Map. |
| DefaultMBeanAttributeFilter | |
| DefaultMBeanObjectConverter | |
| DefaultMessageBuilderFactory | |
| DefaultMessageConverter |
Default
MessageConverter; delegates to a SyslogToMapTransformer to
convert the payload to a map of values and also provides some of the map contents as
message headers. |
| DefaultMessageSplitter |
The default Message Splitter implementation.
|
| DefaultMqttPahoClientFactory |
Creates a default
MqttClient and a set of options as configured. |
| DefaultMqttPahoClientFactory.Will | |
| DefaultMultipartFileReader |
MultipartFileReader implementation that reads the MultipartFile
content directly into a new MultipartFile instance that is not restricted
to the HTTP request scope. |
| DefaultOutboundChannelAdapterParser |
Parser for the <outbound-channel-adapter/> element.
|
| DefaultPahoMessageConverter |
Default implementation for mapping to/from Messages.
|
| DefaultRouterParser |
Parser for the <router/> element.
|
| DefaultScriptExecutor |
Default implementation of the
AbstractScriptExecutor. |
| DefaultScriptVariableGenerator |
A default
ScriptVariableGenerator implementation; used by script processors. |
| DefaultSessionFactoryLocator<F> |
The default implementation of
SessionFactoryLocator using a simple map lookup
and an optional default to fall back on. |
| DefaultSftpSessionFactory |
Factory for creating
SftpSession instances. |
| DefaultSoapHeaderMapper |
A
HeaderMapper implementation for
mapping to and from a SoapHeader. |
| DefaultTcpNetConnectionSupport |
Default implementation of
TcpNetConnectionSupport. |
| DefaultTcpNetSocketFactorySupport |
Implementation of TcpSocketFactorySupport
for non-SSL sockets
ServerSocket and
Socket. |
| DefaultTcpNetSSLSocketFactorySupport | |
| DefaultTcpNioConnectionSupport |
Implementation of
TcpNioConnectionSupport for non-SSL
NIO connections. |
| DefaultTcpNioSSLConnectionSupport |
Implementation of
TcpNioConnectionSupport for SSL
NIO connections. |
| DefaultTcpSocketSupport |
Default implementation of
TcpSocketSupport; makes no
changes to sockets. |
| DefaultTcpSSLContextSupport |
Default implementation of
TcpSSLContextSupport; uses a
'TLS' (by default) SSLContext, initialized with 'JKS'
keystores, managed by 'SunX509' Key and Trust managers. |
| DefaultTransactionSynchronizationFactory |
Default implementation of
TransactionSynchronizationFactory which takes an instance of
TransactionSynchronizationProcessor allowing you to create a TransactionSynchronization
using {DefaultTransactionSynchronizationFactory.create(Object) method. |
| DefaultXmlPayloadConverter |
Default implementation of
XmlPayloadConverter. |
| DefaultXmppHeaderMapper |
Default implementation of
XmppHeaderMapper. |
| DelayerEndpointSpec |
A
ConsumerEndpointSpec for a DelayHandler. |
| DelayerParser |
Parser for the <delayer> element.
|
| DelayHandler |
A
MessageHandler that is capable of delaying the continuation of a Message flow
based on the result of evaluation delayExpression on an inbound Message
or a default delay value configured on this handler. |
| DelayHandler.DelayedMessageWrapper | |
| DelayHandlerManagement | |
| DelegatingMessageGroupProcessor |
The
MessageGroupProcessor implementation with delegation to the provided delegate
and optional aggregation for headers. |
| DelegatingSessionFactory<F> | |
| DerbyChannelMessageStoreQueryProvider | |
| DirectChannel |
A channel that invokes a single subscriber for each sent Message.
|
| DirectChannelSpec | |
| DirectMessageListenerContainerSpec |
Spec for a
DirectMessageListenerContainer. |
| DirectoryCreatedEvent |
An event emitted when a directory is created.
|
| DirectoryCreatedEvent |
An event emitted when a directory is created.
|
| DirectoryScanner |
Strategy for scanning directories.
|
| DiscardAwareFileListFilter<F> |
The
FileListFilter modification which can accept a Consumer
which can be called when the filter discards the file. |
| DiscardingMessageHandler |
Classes implementing this interface are capable of discarding messages.
|
| DiscardingMessageHandlerNode |
Represents an endpoint that has a discard channel.
|
| DomResultFactory | |
| DomSourceFactory |
SourceFactory implementation which supports creation of a DOMSource
from a Document, File or String payload. |
| DslIntegrationConfigurationInitializer |
The Java DSL Integration infrastructure
beanFactory initializer. |
| DynamicExpression |
An implementation of
Expression that delegates to an ExpressionSource
for resolving the actual Expression instance per-invocation at runtime. |
| DynamicJmsTemplate | |
| DynamicPeriodicTrigger |
This is a dynamically changeable
Trigger. |
| EmbeddedJsonHeadersMessageMapper |
For outbound messages, uses a message-aware Jackson object mapper to render the message
as JSON.
|
| EnableIntegration |
The main configuration annotation to enable Spring Integration infrastructure:
- Registers some built-in beans;
- Adds several
BeanFactoryPostProcessors;
- Adds several BeanPostProcessors;
- Adds annotations processors. |
| EnableIntegrationGraphController |
Enables the
IntegrationGraphController if
org.springframework.web.servlet.DispatcherServlet or
org.springframework.web.reactive.DispatcherHandler is present in the classpath. |
| EnableIntegrationManagement |
Enables default configuring of management in Spring Integration components in an existing application.
|
| EnableIntegrationMBeanExport |
Enables default exporting for Spring Integration components in an existing application, as
well as well all
@ManagedResource annotated beans. |
| EnableMessageHistory |
Enables
MessageHistory for Integration components. |
| EnablePublisher |
Provides the registration for the
PublisherAnnotationBeanPostProcessor
to allow the use of the Publisher annotation. |
| EncodingPayloadTransformer<T> |
AbstractPayloadTransformer that delegates to a codec to encode the
payload into a byte[]. |
| EndpointId |
When used alongside an EIP annotation (and no
@Bean), specifies the bean name of
the consumer bean with the handler bean being id.handler (for a consuming
endpoint) or id.source for a message source (e.g. |
| EndpointNode |
Base class for all endpoints.
|
| EndpointSpec<S extends EndpointSpec<S,F,H>,F extends BeanNameAware,H> |
An
IntegrationComponentSpec for endpoints. |
| EndpointUtils |
Utility methods for messaging endpoints.
|
| EnricherParser |
Parser for the 'enricher' element.
|
| EnricherSpec |
A
ConsumerEndpointSpec extension for the ContentEnricher. |
| EqualsResultMatcher<U> |
A matcher that evaluates against the result of invoking a function,
wrapped by the
Supplier
The goal is to defer the computation until the matcher needs to be actually evaluated. |
| ErrorCapableCompositeMessageHandlerNode |
Represents a composite message handler that can emit error messages
(pollable endpoint).
|
| ErrorCapableDiscardingMessageHandlerNode |
Represents an endpoint that has a discard channel and can emit errors
(pollable endpoint).
|
| ErrorCapableEndpointNode |
Represents nodes that can natively handle errors.
|
| ErrorCapableMessageHandlerNode |
Represents a message handler that can produce errors (pollable).
|
| ErrorCapableNode |
Nodes implementing this interface are capable of emitting errors.
|
| ErrorCapableRoutingNode |
Represents an endpoint that can route to multiple channels and can emit errors
(pollable endpoint).
|
| ErrorHandlingTaskExecutor |
A
TaskExecutor implementation that wraps an existing Executor
instance in order to catch any exceptions. |
| ErrorMessageExceptionTypeRouter |
A Message Router that resolves the target
MessageChannel for
messages whose payload is a Throwable. |
| ErrorMessageExceptionTypeRouterParser |
Parser for the <exception-type-router/> element.
|
| ErrorMessageJacksonDeserializer |
The
MessageJacksonDeserializer implementation for the ErrorMessage. |
| ErrorMessagePublisher |
The component which can be used as general purpose of errors publishing.
|
| ErrorMessageSendingRecoverer |
A
RecoveryCallback that sends the final throwable as an
ErrorMessage after
retry exhaustion. |
| ErrorMessageSendingRecoverer.RetryExceptionNotAvailableException | |
| ErrorMessageStrategy |
A strategy to build an
ErrorMessage based on the provided
Throwable and AttributeAccessor as a context. |
| ErrorMessageUtils |
Utilities for building error messages.
|
| EventDrivenConsumer |
Message Endpoint that connects any
MessageHandler implementation to a SubscribableChannel. |
| EventInboundChannelAdapterParser | |
| EventNamespaceHandler |
Namespace handler for Spring Integration's 'event' namespace.
|
| EventOutboundChannelAdapterParser | |
| EventType |
Enumeration of GemFire event types.
|
| ExecutorChannel |
An implementation of
MessageChannel
that delegates to an instance of
UnicastingDispatcher which in turn delegates all dispatching
invocations to an Executor. |
| ExecutorChannelInterceptorAware |
The
InterceptableChannel extension for the cases when
the ExecutorChannelInterceptors
may have reason (e.g. |
| ExecutorChannelSpec | |
| ExpirableLockRegistry |
A
LockRegistry implementing this interface supports the removal of aged locks
that are not currently locked. |
| ExpressionArgumentsStrategy | |
| ExpressionCapable |
Components that implement this interface are capable of supporting a primary
SpEL expression as part of their configuration.
|
| ExpressionCommandMessageProcessor |
A MessageProcessor implementation that expects an Expression or expressionString
as the Message payload.
|
| ExpressionControlBusFactoryBean |
FactoryBean for creating
MessageHandler instances to handle a message as a SpEL expression. |
| ExpressionEvalMap |
An immutable
AbstractMap implementation that wraps a Map<String, Object>,
where values must be instances of String or Expression,
and evaluates an expression for the provided key from the underlying
original Map. |
| ExpressionEvalMap.ComponentsEvaluationCallback |
The
ExpressionEvalMap.EvaluationCallback implementation which evaluates an expression using
the provided context, root and returnType variables. |
| ExpressionEvalMap.EvaluationCallback |
Implementations of this interface can be provided to build 'on demand
ExpressionEvalMap.get(Object) logic'
for ExpressionEvalMap. |
| ExpressionEvalMap.ExpressionEvalMapBuilder |
The builder class to instantiate
ExpressionEvalMap. |
| ExpressionEvalMap.ExpressionEvalMapComponentsBuilder | |
| ExpressionEvalMap.ExpressionEvalMapFinalBuilder | |
| ExpressionEvaluatingCorrelationStrategy |
CorrelationStrategy implementation that evaluates an expression. |
| ExpressionEvaluatingHeaderValueMessageProcessor<T> | |
| ExpressionEvaluatingMessageGroupProcessor |
A
MessageGroupProcessor implementation that evaluates a SpEL expression. |
| ExpressionEvaluatingMessageHandler |
A
MessageHandler that evaluates
the provided Expression expecting a void return. |
| ExpressionEvaluatingMessageListProcessor |
A base class for aggregators that evaluates a SpEL expression with the message list as the root object within the
evaluation context.
|
| ExpressionEvaluatingMessageProcessor<T> |
A
MessageProcessor implementation that evaluates a SpEL expression
with the Message itself as the root object within the evaluation context. |
| ExpressionEvaluatingMessageSource<T> | |
| ExpressionEvaluatingParameterSourceFactory |
A SpEL expression based
ParameterSourceFactory implementation. |
| ExpressionEvaluatingReleaseStrategy |
A
ReleaseStrategy that evaluates an expression. |
| ExpressionEvaluatingRequestHandlerAdvice |
Used to advise
MessageHandlers. |
| ExpressionEvaluatingRequestHandlerAdvice.MessageHandlingExpressionEvaluatingAdviceException | |
| ExpressionEvaluatingRouter |
A Message Router implementation that evaluates the specified SpEL
expression.
|
| ExpressionEvaluatingRoutingSlipRouteStrategy |
The
Expression based RoutingSlipRouteStrategy implementation. |
| ExpressionEvaluatingRoutingSlipRouteStrategy.RequestAndReply | |
| ExpressionEvaluatingSelector |
A
MessageSelector implementation that
evaluates a SpEL expression. |
| ExpressionEvaluatingSplitter |
A Message Splitter implementation that evaluates the specified SpEL
expression.
|
| ExpressionEvaluatingSqlParameterSourceFactory |
An implementation of
SqlParameterSourceFactory which creates
an SqlParameterSource that evaluates Spring EL expressions. |
| ExpressionEvaluatingTransactionSynchronizationProcessor |
This implementation of
TransactionSynchronizationFactory
allows you to configure SpEL expressions, with their execution being coordinated
(synchronized) with a transaction - see
TransactionSynchronization. |
| ExpressionEvaluatingTransformer |
A Message Transformer implementation that evaluates the specified SpEL
expression.
|
| ExpressionFactoryBean |
FactoryBean for creating Expression instances.
|
| ExpressionFileListFilter<F> |
A SpEL expression based
AbstractFileListFilter implementation. |
| ExpressionMessageProducerSupport |
A
MessageProducerSupport sub-class that provides ExpressionMessageProducerSupport.payloadExpression
evaluation with result as a payload for Message to send. |
| ExpressionSource |
Strategy interface for retrieving Expressions.
|
| ExpressionUtils |
Utility class with static methods for helping with evaluation of SpEL expressions.
|
| FailoverClientConnectionFactory |
Given a list of connection factories, serves up
TcpConnections
that can iterate over a connection from each factory until the write
succeeds or the list is exhausted. |
| Feed |
The Spring Integration Feed components Factory.
|
| FeedEntryMessageSource |
This implementation of
MessageSource will
produce individual SyndEntrys for a feed identified with the 'feedUrl'
attribute. |
| FeedEntryMessageSourceSpec |
A
MessageSourceSpec for a FeedEntryMessageSource. |
| FeedInboundChannelAdapterParser |
Handles parsing the configuration for the feed inbound-channel-adapter.
|
| FeedNamespaceHandler |
NamespaceHandler for the feed module.
|
| FileCopyingMultipartFileReader |
MultipartFileReader implementation that copies the MultipartFile's
content to a new temporary File in the specified directory. |
| FileExistsMode |
When writing file, this enumeration indicates what action shall be taken in
case the destination file already exists.
|
| FileHeaders |
Pre-defined header names to be used when storing or retrieving
File-related values to/from integration Message Headers.
|
| FileInboundChannelAdapterParser |
Parser for the <inbound-channel-adapter> element of the 'file' namespace.
|
| FileInboundChannelAdapterSpec | |
| FileInfo<F> |
Represents a remote file info - an abstraction over the underlying implementation.
|
| FileIntegrationEvent | |
| FileKryoRegistrar |
A
KryoRegistrar used to validateRegistration a File serializer. |
| FileListFilter<F> |
Strategy interface for filtering a group of files.
|
| FileListFilterFactoryBean | |
| FileLocker |
A FileLocker is a strategy that can ensure that files are only processed a
single time.
|
| FileNameGenerator |
Strategy interface for generating a file name from a message.
|
| FileNamespaceHandler |
Namespace handler for Spring Integration's 'file' namespace.
|
| FileOutboundChannelAdapterParser |
Parser for the <outbound-channel-adapter/> element of the 'file'
namespace.
|
| FileOutboundGatewayParser |
Parser for the 'outbound-gateway' element of the file namespace.
|
| FileParserUtils | |
| FileReadingMessageSource |
MessageSource that creates messages
from a file system directory. |
| FileReadingMessageSource.WatchEventType | |
| FileReadingMessageSourceFactoryBean | |
| Files |
The Spring Integration File components Factory.
|
| FileSerializer |
A custom Kryo
Serializer for serializing File payloads. |
| FileServerEvent |
Base class for file server events.
|
| FileSplitter |
The
AbstractMessageSplitter implementation to split the File Message
payload to lines. |
| FileSplitter.FileMarker | |
| FileSplitter.FileMarker.Mark | |
| FileSplitterParser | |
| FileSplitterSpec |
The
MessageHandlerSpec for the FileSplitter. |
| FileSystemMarkerFilePresentFileListFilter |
File system implementation of
AbstractMarkerFilePresentFileListFilter. |
| FileSystemPersistentAcceptOnceFileListFilter | |
| FileTailInboundChannelAdapterFactoryBean | |
| FileTailInboundChannelAdapterParser | |
| FileTailingMessageProducerSupport |
Base class for file tailing inbound adapters.
|
| FileTailingMessageProducerSupport.FileTailingEvent | |
| FileTailingMessageProducerSupport.FileTailingIdleEvent | |
| FileToByteArrayTransformer |
A payload transformer that copies a File's contents to a byte array.
|
| FileToByteArrayTransformerParser |
Parser for the <file-to-bytes-transformer> element.
|
| FileToStringTransformer |
A payload transformer that copies a File's contents to a String.
|
| FileToStringTransformerParser |
Parser for the <file-to-string-transformer> element.
|
| FileTransferringMessageHandler<F> |
A
MessageHandler implementation that transfers files to a remote server. |
| FileTransferringMessageHandlerSpec<F,S extends FileTransferringMessageHandlerSpec<F,S>> |
The
MessageHandlerSpec for the FileTransferringMessageHandler. |
| FileUtils |
Utilities for operations on Files.
|
| FileWritingMessageHandler |
A
MessageHandler implementation
that writes the Message payload to a
file. |
| FileWritingMessageHandler.FlushPredicate |
When using
FileExistsMode.APPEND_NO_FLUSH, an implementation of this
interface is called for each file that has pending data to flush and close when
FileWritingMessageHandler.flushIfNeeded(FlushPredicate) is invoked. |
| FileWritingMessageHandler.MessageFlushPredicate |
When using
FileExistsMode.APPEND_NO_FLUSH
an implementation of this interface is called for each file that has pending data
to flush when a trigger message is received. |
| FileWritingMessageHandlerFactoryBean |
Factory bean used to create
FileWritingMessageHandlers. |
| FileWritingMessageHandlerSpec |
The
MessageHandlerSpec for the FileWritingMessageHandler. |
| FileWrittenEvent |
An event that is emitted when a file is written.
|
| FileWrittenEvent |
An event that is emitted when a file is written.
|
| Filter |
Indicates that a method is capable of playing the role of a Message Filter.
|
| FilterAnnotationPostProcessor |
Post-processor for Methods annotated with
@Filter. |
| FilterEndpointSpec |
A
ConsumerEndpointSpec implementation for the MessageFilter. |
| FilterFactoryBean |
Factory bean for creating a Message Filter.
|
| FilterParser |
Parser for the <filter/> element.
|
| FixedMethodFilter |
A
MethodFilter implementation that will always return
the same Method instance within a single-element list if it is
present in the candidate list. |
| FixedSubscriberChannel |
Specialized
SubscribableChannel for a single final subscriber set up during bean instantiation (unlike
other SubscribableChannels where the MessageHandler is subscribed when the endpoint
is started). |
| FixedSubscriberChannelBeanFactoryPostProcessor |
Used to post process candidates for
FixedSubscriberChannel
MessageHandlers. |
| FixedSubscriberChannelPrototype |
An "artificial"
MessageChannel implementation which will be unwrapped to the
FixedSubscriberChannel on the bean
registration phase. |
| FluxAggregatorMessageHandler |
The
AbstractMessageProducingHandler implementation for aggregation logic based
on Reactor's Flux.groupBy(java.util.function.Function<? super T, ? extends K>) and Flux.window(int) operators. |
| FluxMessageChannel |
The
AbstractMessageChannel implementation for the
Reactive Streams Publisher based on the Project Reactor Flux. |
| FluxMessageChannelSpec | |
| Ftp |
The factory for FTP components.
|
| FtpFileInfo |
A
FileInfo implementation for
FTP/FTPS. |
| FtpInboundChannelAdapterParser |
Parser for the FTP 'inbound-channel-adapter' element.
|
| FtpInboundChannelAdapterSpec | |
| FtpInboundFileSynchronizer |
An implementation of
AbstractInboundFileSynchronizer for FTP. |
| FtpInboundFileSynchronizingMessageSource |
A
MessageSource implementation for FTP. |
| FtpMessageHandler |
The FTP specific
FileTransferringMessageHandler extension. |
| FtpMessageHandlerSpec |
A
FileTransferringMessageHandlerSpec for FTP. |
| FtpNamespaceHandler |
Provides namespace support for using FTP
|
| FtpOutboundChannelAdapterParser |
Parser for FTP Outbound Channel Adapters.
|
| FtpOutboundGateway |
Outbound Gateway for performing remote file operations via FTP/FTPS.
|
| FtpOutboundGatewayParser | |
| FtpOutboundGatewaySpec |
A
RemoteFileOutboundGatewaySpec for FTP. |
| FtpPersistentAcceptOnceFileListFilter |
Persistent file list filter using the server's file timestamp to detect if we've already
'seen' this file.
|
| FtpRegexPatternFileListFilter |
Implementation of
AbstractRegexPatternFileListFilter for FTP. |
| FtpRemoteFileTemplate |
FTP version of
RemoteFileTemplate providing type-safe access to
the underlying FTPClient object. |
| FtpRemoteFileTemplate.ExistsMode |
The
FtpRemoteFileTemplate.exists(String) operation mode. |
| FtpRequestEvent |
Base class for all events having an
FtpRequest. |
| FtpSession |
Implementation of
Session for FTP. |
| FtpSimplePatternFileListFilter |
Implementation of
AbstractSimplePatternFileListFilter for FTP. |
| FtpStreamingInboundChannelAdapterParser | |
| FtpStreamingInboundChannelAdapterSpec | |
| FtpStreamingMessageSource |
Message source for streaming FTP remote file contents.
|
| FtpSystemMarkerFilePresentFileListFilter |
FTP implementation of
AbstractMarkerFilePresentFileListFilter. |
| FunctionExpression<S> | |
| FunctionIterator<T,V> |
An
Iterator implementation to convert each item from the target
FunctionIterator.iterator to a new object applying the FunctionIterator.function on FunctionIterator.next(). |
| Gateway |
Indicates that an interface method is capable of mapping its parameters
to a message or message payload.
|
| GatewayEndpointSpec |
A
ConsumerEndpointSpec implementation for a mid-flow GatewayMessageHandler. |
| GatewayHeader |
Provides the message header
value or expression. |
| GatewayMessageHandler |
The
AbstractReplyProducingMessageHandler implementation for mid-flow Gateway. |
| GatewayMethodMetadata |
Represents the metadata associated with a Gateway method.
|
| GatewayParser |
Parser for the <gateway/> element.
|
| GatewayProxyFactoryBean |
Generates a proxy for the provided service interface to enable interaction
with messaging components without application code being aware of them allowing
for POJO-style interaction.
|
| GatewayProxySpec |
A builder for the
GatewayProxyFactoryBean options
when MessagingGateway on the service interface cannot be
declared. |
| GaugeFacade | |
| GemfireCqInboundChannelAdapterParser | |
| GemfireInboundChannelAdapterParser | |
| GemfireIntegrationNamespaceHandler | |
| GemfireLockRegistry |
Implementation of
LockRegistry providing a distributed lock using Gemfire. |
| GemfireMessageStore |
Gemfire implementation of the key/value style
MessageStore and
MessageGroupStore |
| GemfireMetadataStore |
Gemfire implementation of
ListenableMetadataStore. |
| GemfireOutboundChannelAdapterParser | |
| GeneralSftpException |
Simple runtime exception to wrap an SftpException.
|
| GenericEndpointSpec<H extends MessageHandler> |
A
ConsumerEndpointSpec for a MessageHandler implementations. |
| GenericHandler<P> |
A functional interface to specify
MessageHandler
logic with Java 8 Lambda expression: |
| GenericMessageJacksonDeserializer |
The
MessageJacksonDeserializer implementation for the GenericMessage. |
| GenericSelector<S> |
Generic (lambda) strategy interface for selector.
|
| GenericTransformer<S,T> |
Generic (lambda) strategy interface for transformer.
|
| GlobalChannelInterceptor |
ChannelInterceptor components with this
annotation will be applied as global channel interceptors
using the provided patterns to match channel names. |
| GlobalChannelInterceptorInitializer |
The
IntegrationConfigurationInitializer to populate GlobalChannelInterceptorWrapper
for ChannelInterceptors marked with
GlobalChannelInterceptor annotation. |
| GlobalChannelInterceptorParser |
Parser for 'channel-interceptor' elements.
|
| GlobalChannelInterceptorProcessor |
This class applies global interceptors (
<channel-interceptor> or @GlobalChannelInterceptor)
to message channels beans. |
| GlobalChannelInterceptorWrapper | |
| GlobalWireTapParser |
Parser for the top level 'wire-tap' element
|
| Graph |
This object can be exposed, for example, as a JSON object over
HTTP.
|
| GroovyAwareScriptExecutingProcessorFactory |
The factory to create
GroovyScriptExecutingMessageProcessor instances
if provided language == "groovy", otherwise delegates to the super class. |
| GroovyCommandMessageProcessor | |
| GroovyControlBusFactoryBean |
FactoryBean for creating
MessageHandler instances to handle a message as a Groovy Script. |
| GroovyControlBusParser |
Parser for the <groovy:control-bus/> element.
|
| GroovyIntegrationConfigurationInitializer |
The Groovy Module Integration infrastructure
beanFactory initializer. |
| GroovyNamespaceHandler | |
| GroovyScriptExecutingMessageProcessor |
The
MessageProcessor implementation
to evaluate Groovy scripts. |
| GroovyScriptParser |
Parser for the <groovy:script/> element.
|
| H2ChannelMessageStoreQueryProvider | |
| HandleMessageAdvice |
The marker
MethodInterceptor interface extension
to distinguish advices for some reason. |
| HandleMessageAdviceAdapter |
A
HandleMessageAdvice implementation with a plain delegation
to the provided MethodInterceptor. |
| HeadDirectoryScanner |
A custom scanner that only returns the first
maxNumberOfFiles
elements from a directory listing. |
| HeaderAttributeCorrelationStrategy |
Default implementation of
CorrelationStrategy. |
| HeaderChannelRegistry |
Implementations convert a channel to a name, retaining a reference to the channel keyed by the name.
|
| HeaderEnricher |
A Transformer that adds statically configured header values to a Message.
|
| HeaderEnricherParserSupport |
Base support class for 'header-enricher' parsers.
|
| HeaderEnricherSpec |
An
IntegrationComponentSpec for a HeaderEnricher. |
| HeaderFilter |
Transformer that removes Message headers.
|
| HeaderFilterParser |
Parser for the 'header-filter' element.
|
| HeaderMapper<T> |
Generic strategy interface for mapping
MessageHeaders to and from other
types of objects. |
| HeaderMatcher<T> |
Are the
MessageHeaders of a Message containing any entry
or multiple that match? |
| HeaderPropagationAware |
MessageHandlers implementing this interface can propagate headers from
an input message to an output message.
|
| HeaderValueMessageProcessor<T> | |
| HeaderValueRouter |
A Message Router that resolves the MessageChannel from a header value.
|
| HeaderValueRouterParser |
Parser for the <header-value-router/> element.
|
| HeapDumper |
Use to take a heap dump programmatically.
|
| HistoryWritingMessagePostProcessor | |
| HsqlChannelMessageStoreQueryProvider | |
| Http |
The HTTP components Factory.
|
| HttpContextUtils |
Utility class for accessing HTTP integration components
from the
BeanFactory. |
| HttpControllerEndpointSpec |
The
BaseHttpInboundEndpointSpec implementation for the HttpRequestHandlingController. |
| HttpHeaders | |
| HttpInboundEndpointParser |
Parser for the 'inbound-channel-adapter' and 'inbound-gateway' elements
of the 'http' namespace.
|
| HttpInboundEndpointSupportSpec<S extends HttpInboundEndpointSupportSpec<S,E>,E extends BaseHttpInboundEndpoint> | |
| HttpInboundEndpointSupportSpec.CrossOriginSpec |
A fluent API for the
CrossOrigin. |
| HttpInboundEndpointSupportSpec.RequestMappingSpec |
A fluent API for the
RequestMapping. |
| HttpIntegrationConfigurationInitializer |
The HTTP Integration infrastructure
beanFactory initializer. |
| HttpMessageHandlerSpec |
The
BaseHttpMessageHandlerSpec implementation for the HttpRequestExecutingMessageHandler. |
| HttpNamespaceHandler |
Namespace handler for Spring Integration's http namespace.
|
| HttpOutboundChannelAdapterParser |
Parser for the 'outbound-channel-adapter' element of the http namespace.
|
| HttpOutboundGatewayParser |
Parser for the 'outbound-gateway' element of the http namespace.
|
| HttpRequestExecutingMessageHandler |
A
MessageHandler
implementation that executes HTTP requests by delegating
to a RestTemplate instance. |
| HttpRequestHandlerEndpointSpec |
The
BaseHttpInboundEndpointSpec implementation for the HttpRequestHandlingMessagingGateway. |
| HttpRequestHandlingController |
Inbound HTTP endpoint that implements Spring's
Controller interface to be used with a DispatcherServlet front
controller. |
| HttpRequestHandlingEndpointSupport |
Base class for HTTP request handling endpoints.
|
| HttpRequestHandlingMessagingGateway |
Inbound Messaging Gateway that handles HTTP Requests.
|
| IdempotentReceiver |
A
method that has a MessagingAnnotation (@code @ServiceActivator, @Router etc.)
that also has this annotation, has an
IdempotentReceiverInterceptor applied
to the associated MessageHandler.handleMessage(org.springframework.messaging.Message<?>) method. |
| IdempotentReceiverAutoProxyCreatorInitializer |
The
IntegrationConfigurationInitializer that populates
the ConfigurableListableBeanFactory
with an IdempotentReceiverAutoProxyCreator
when IdempotentReceiverInterceptor BeanDefinitions and their mapping
to Consumer Endpoints are present. |
| IdempotentReceiverInterceptor |
The
MethodInterceptor implementation for the
Idempotent Receiver
E.I. |
| IdempotentReceiverInterceptorParser |
Parser for the <idempotent-receiver/> element.
|
| IdGeneratorConfigurer | |
| IdGenerators |
Alternative
IdGenerator implementations. |
| IdGenerators.JdkIdGenerator |
UUID.randomUUID()
|
| IdGenerators.SimpleIncrementingIdGenerator | |
| IgnoreHiddenFileListFilter |
FileListFilter implementation that ignores any hidden files. |
| ImapIdleChannelAdapter |
An event-driven Channel Adapter that receives mail messages from a mail
server that supports the IMAP "idle" command (see RFC 2177).
|
| ImapIdleChannelAdapterParser |
Parser for the <imap-idle-channel-adapter> element in the 'mail' namespace.
|
| ImapIdleChannelAdapterSpec | |
| ImapMailInboundChannelAdapterSpec |
A
MailInboundChannelAdapterSpec for IMAP. |
| ImapMailReceiver |
A
MailReceiver implementation for receiving mail messages from a
mail server that supports the IMAP protocol. |
| InboundChannelAdapter | |
| InboundChannelAdapterAnnotationPostProcessor |
Post-processor for Methods annotated with
@InboundChannelAdapter. |
| InboundFileSynchronizer |
Strategy for synchronizing from a remote File system to a local directory.
|
| InboundMessageMapper<T> |
Strategy interface for mapping from an Object to a
Message. |
| InputStreamCallback |
Callback for stream-based file retrieval using a RemoteFileOperations.
|
| IntegrationComponentScan |
Configures component scanning directives for use with
Configuration classes. |
| IntegrationComponentScanRegistrar |
ImportBeanDefinitionRegistrar implementation to scan and register Integration specific components. |
| IntegrationComponentSpec<S extends IntegrationComponentSpec<S,T>,T> |
The common Builder abstraction.
|
| IntegrationConfigurationBeanFactoryPostProcessor |
BeanDefinitionRegistryPostProcessor to apply external Integration
infrastructure configurations via loading IntegrationConfigurationInitializer
implementations using SpringFactoriesLoader. |
| IntegrationConfigurationInitializer |
The strategy to initialize the external Integration infrastructure (@{code BeanFactoryPostProcessor}s,
global beans etc.) in the provided
beanFactory. |
| IntegrationConfigUtils |
Shared utility methods for Integration configuration.
|
| IntegrationConsumer |
Message consumers implement this interface, the message handler within a consumer
may or may not emit output messages.
|
| IntegrationContextUtils |
Utility methods for accessing common integration components from the BeanFactory.
|
| IntegrationConverter |
A marker annotation (an analogue of
<int:converter/>) to register
Converter,
GenericConverter or
ConverterFactory beans for the integrationConversionService. |
| IntegrationConverterInitializer | |
| IntegrationEvaluationContextFactoryBean | |
| IntegrationEvent |
Base class for all
ApplicationEvents generated by the framework. |
| IntegrationFlow |
The main Integration DSL abstraction.
|
| IntegrationFlowAdapter |
The base
Adapter class for the IntegrationFlow abstraction. |
| IntegrationFlowBeanPostProcessor |
A
BeanPostProcessor to parse IntegrationFlow beans and register their
components as beans in the provided
BeanFactory, if necessary. |
| IntegrationFlowBuilder | |
| IntegrationFlowContext |
A public API for dynamic (manual) registration of
IntegrationFlows,
not via standard bean registration phase. |
| IntegrationFlowContext.IntegrationFlowRegistration | |
| IntegrationFlowContext.IntegrationFlowRegistrationBuilder |
A Builder pattern implementation for the options to register
IntegrationFlow
in the application context. |
| IntegrationFlowDefinition<B extends IntegrationFlowDefinition<B>> |
The
BaseIntegrationFlowDefinition extension for syntax sugar with generics for some
type-based EIP-methods when an expected payload type is assumed from upstream. |
| IntegrationFlowExtension<B extends IntegrationFlowExtension<B>> |
An
IntegrationFlowDefinition extension for custom Java DSL operators
and reusable solutions. |
| IntegrationFlows |
The central factory for fluent
IntegrationFlowBuilder API. |
| IntegrationGraphController |
The REST Controller to provide the management API over
IntegrationGraphServer. |
| IntegrationGraphControllerParser |
The
BeanDefinitionParser for the <int-http:graph-controller> component. |
| IntegrationGraphServer |
Builds the runtime object model graph.
|
| IntegrationHandlerResultHandler |
A
HandlerResultHandler implementation to handle the result of the
WebFluxInboundEndpoint execution. |
| IntegrationInboundManagement |
Marker interface indicating that this
IntegrationManagement component initiates
message flow. |
| IntegrationJmxAttributeSource |
The
AnnotationJmxAttributeSource extension to resolve ManagedResources
via IntegrationManagedResource on classes. |
| IntegrationManagedResource |
Clone of
ManagedResource
limiting beans thus annotated so that they
will only be exported by the IntegrationMBeanExporter and prevented
from being exported by other MBeanExporters (if present). |
| IntegrationManagement |
Base interface for Integration managed components.
|
| IntegrationManagement.ManagementOverrides |
Toggles to inform the management configurer to not set these properties since
the user has manually configured them in a bean definition.
|
| IntegrationManagementConfiguration |
@Configuration class that registers a IntegrationManagementConfigurer bean. |
| IntegrationManagementConfigurer |
Configures beans that implement
IntegrationManagement. |
| IntegrationManagementParser |
Parser for the <management/> element.
|
| IntegrationMBeanExportConfiguration |
@Configuration class that registers a IntegrationMBeanExporter bean. |
| IntegrationMBeanExporter |
MBean exporter for Spring Integration components in an existing application.
|
| IntegrationMessageHeaderAccessor |
Adds standard SI Headers.
|
| IntegrationNamespaceHandler |
Namespace handler for the integration namespace.
|
| IntegrationNamespaceUtils |
Shared utility methods for integration namespace parsers.
|
| IntegrationNode |
Base class for all nodes.
|
| IntegrationObjectSupport |
A base class that provides convenient access to the bean factory as
well as
TaskScheduler and ConversionService instances. |
| IntegrationPattern |
Indicates that a component implements some Enterprise Integration Pattern.
|
| IntegrationPatternType |
The Enterprise Integration Pattern types.
|
| IntegrationPatternType.IntegrationPatternCategory |
The Enterprise Integration Pattern categories.
|
| IntegrationProperties |
Utility class to encapsulate infrastructure Integration properties constants and
their default values from resources 'META-INF/spring.integration.default.properties'.
|
| IntegrationReactiveUtils |
Utilities for adapting integration components to/from reactive types.
|
| IntegrationRegistrar |
ImportBeanDefinitionRegistrar implementation that configures integration infrastructure. |
| IntegrationRequestMappingHandlerMapping |
The
HandlerMapping implementation that
detects and registers RequestMappingInfos for
HttpRequestHandlingEndpointSupport from a Spring Integration HTTP configuration
of <inbound-channel-adapter/> and <inbound-gateway/> elements. |
| IntegrationResourceHolder |
An implementation of the
ResourceHolder which holds an instance of the current Message
and the synchronization resource |
| IntegrationResourceHolderSynchronization |
The base
ResourceHolderSynchronization for IntegrationResourceHolder. |
| IntegrationRSocketEndpoint |
A marker
ReactiveMessageHandler extension interface for Spring Integration
inbound endpoints. |
| IntegrationSecurityNamespaceHandler |
Namespace handler for the security namespace.
|
| IntegrationSimpleEvaluationContextFactoryBean |
FactoryBean to populate SimpleEvaluationContext instances enhanced with:
a TypeConverter based on the
ConversionService
from the application context. |
| IntegrationStompHeaders |
The STOMP headers with Integration-friendly
stomp_ prefix. |
| IntegrationUtils |
General utility methods.
|
| IntegrationWebExchangeBindException |
A
WebExchangeBindException extension for validation error with a failed
message context. |
| IntegrationWebSocketContainer |
The high-level 'connection factory pattern' contract over low-level Web-Socket
configuration.
|
| IntegrationXmlNamespaceHandler | |
| IpAdapterParserUtils |
Utility methods and constants for IP adapter parsers.
|
| IpHeaders |
Headers for Messages mapped from IP datagram packets.
|
| IpIntegrationEvent | |
| IpNamespaceHandler |
Namespace handler for Spring Integration's ip namespace.
|
| Jackson2JsonMessageParser |
JsonInboundMessageMapper.JsonMessageParser implementation that parses JSON messages
and builds a Message with the specified payload type from provided JsonInboundMessageMapper. |
| Jackson2JsonObjectMapper |
Jackson 2 JSON-processor (@link https://github.com/FasterXML)
JsonObjectMapper implementation.
|
| JacksonJsonUtils |
Utility methods for Jackson.
|
| JacksonPresent |
The utility to check if Jackson JSON processor is present in the classpath.
|
| JavaUtils |
Chained utility methods to simplify some Java repetitive code.
|
| JdbcChannelMessageStore |
Channel-specific implementation of
MessageGroupStore using a relational
database via JDBC. |
| JdbcLockRegistry |
An
ExpirableLockRegistry using a shared database to co-ordinate the locks. |
| JdbcMessageHandler |
A message handler that executes an SQL update.
|
| JdbcMessageHandlerParser | |
| JdbcMessageStore |
Implementation of
MessageStore using a relational database via JDBC. |
| JdbcMessageStoreParser |
Parser for
JdbcMessageStore. |
| JdbcMetadataStore |
Implementation of
ConcurrentMetadataStore using a relational database via JDBC. |
| JdbcNamespaceHandler |
Namespace handler for the integration JDBC schema.
|
| JdbcOutboundGateway | |
| JdbcOutboundGatewayParser | |
| JdbcPollingChannelAdapter |
A polling channel adapter that creates messages from the payload returned by
executing a select query.
|
| JdbcPollingChannelAdapterParser |
Parser for
JdbcPollingChannelAdapter. |
| JdbcTypesEnum |
This Enumeration provides a handy wrapper around
Types. |
| Jms |
Factory class for JMS components.
|
| JmsAdapterUtils | |
| JmsChannelFactoryBean | |
| JmsChannelParser |
Parser for the 'channel' and 'publish-subscribe-channel' elements of the
Spring Integration JMS namespace.
|
| JmsDefaultListenerContainerSpec |
A
DefaultMessageListenerContainer specific JmsListenerContainerSpec extension. |
| JmsDestinationAccessorSpec<S extends JmsDestinationAccessorSpec<S,A>,A extends JmsDestinationAccessor> |
A base
IntegrationComponentSpec for JmsDestinationAccessors. |
| JmsDestinationPollingSource |
A source for receiving JMS Messages with a polling listener.
|
| JmsHeaderEnricherParser |
Header enricher for JMS specific values.
|
| JmsHeaderMapper |
Strategy interface for mapping integration Message headers to an outbound
JMS Message (e.g.
|
| JmsInboundChannelAdapterParser |
Parser for the <inbound-channel-adapter/> element of the 'jms' namespace.
|
| JmsInboundChannelAdapterSpec<S extends JmsInboundChannelAdapterSpec<S>> | |
| JmsInboundChannelAdapterSpec.JmsInboundChannelSpecTemplateAware |
A
JmsTemplate-based JmsInboundChannelAdapterSpec extension. |
| JmsInboundGateway |
A wrapper around the
JmsMessageDrivenEndpoint implementing
MessagingGatewaySupport. |
| JmsInboundGatewaySpec<S extends JmsInboundGatewaySpec<S>> |
A
MessagingGatewaySpec for a JmsInboundGateway. |
| JmsInboundGatewaySpec.JmsInboundGatewayListenerContainerSpec<S extends JmsListenerContainerSpec<S,C>,C extends AbstractMessageListenerContainer> |
An
AbstractMessageListenerContainer-based JmsInboundGatewaySpec extension. |
| JmsListenerContainerSpec<S extends JmsListenerContainerSpec<S,C>,C extends AbstractMessageListenerContainer> | |
| JmsMessageChannelSpec<S extends JmsMessageChannelSpec<S,T>,T extends AbstractJmsChannel> |
A
JmsMessageChannelSpec for subscribable
AbstractJmsChannels. |
| JmsMessageDrivenChannelAdapterSpec<S extends JmsMessageDrivenChannelAdapterSpec<S>> | |
| JmsMessageDrivenChannelAdapterSpec.JmsMessageDrivenChannelAdapterListenerContainerSpec<S extends JmsListenerContainerSpec<S,C>,C extends AbstractMessageListenerContainer> | |
| JmsMessageDrivenEndpoint |
A message-driven endpoint that receive JMS messages, converts them into
Spring Integration Messages, and then sends the result to a channel.
|
| JmsMessageDrivenEndpointParser |
Parser for the <message-driven-channel-adapter> element and the
<inbound-gateway> element of the 'jms' namespace.
|
| JmsNamespaceHandler |
Namespace handler for Spring Integration's jms namespace.
|
| JmsOutboundChannelAdapterParser |
Parser for the <outbound-channel-adapter/> element of the jms namespace.
|
| JmsOutboundChannelAdapterSpec<S extends JmsOutboundChannelAdapterSpec<S>> | |
| JmsOutboundChannelAdapterSpec.JmsOutboundChannelSpecTemplateAware |
A
JmsTemplate-based JmsOutboundChannelAdapterSpec extension. |
| JmsOutboundGateway |
An outbound Messaging Gateway for request/reply JMS.
|
| JmsOutboundGateway.ReplyContainerProperties | |
| JmsOutboundGatewayParser |
Parser for the <outbound-gateway> element of the integration 'jms' namespace.
|
| JmsOutboundGatewaySpec |
A
MessageHandlerSpec for a JmsOutboundGateway. |
| JmsPollableMessageChannelSpec<S extends JmsPollableMessageChannelSpec<S,T>,T extends AbstractJmsChannel> |
A
MessageChannelSpec for an AbstractJmsChannel. |
| JmsPublishSubscribeMessageChannelSpec |
A
JmsMessageChannelSpec for a SubscribableJmsChannel
configured with a topic. |
| JmsSendingMessageHandler |
A MessageConsumer that sends the converted Message payload within a JMS Message.
|
| JmsTemplateSpec | |
| JmsTimeoutException |
A timeout occurred within an async gateway.
|
| JmxHeaders |
Constants for JMX related Message Header keys.
|
| JmxIntegrationConfigurationInitializer |
The JMX Integration infrastructure
beanFactory initializer. |
| JmxNamespaceHandler |
Namespace handler for Spring Integration's jmx namespace.
|
| Jpa |
Factory class for JPA components.
|
| JpaBaseOutboundEndpointSpec<S extends JpaBaseOutboundEndpointSpec<S>> |
The base
MessageHandlerSpec for JPA Outbound endpoints. |
| JpaExecutor |
Executes Jpa Operations that produce payload objects from the result of the provided:
entityClass
JpQl Select Query
Sql Native Query
JpQl Named Query
Sql Native Named Query
When objects are being retrieved, it also possibly to:
delete the retrieved object
If neither entityClass nor any other query is specified then the entity-class
is "guessed" from the
Message payload.idExpression |
| JpaInboundChannelAdapterParser |
The JPA Inbound Channel adapter parser
|
| JpaInboundChannelAdapterSpec | |
| JpaNamespaceHandler |
The namespace handler for the JPA namespace
|
| JpaOperationFailedException |
An Exception that would be thrown if any of the Operations from
JpaOperations fails |
| JpaOperations |
The Interface containing all the JpaOperations those will be executed by
the Jpa Spring Integration components.
|
| JpaOutboundChannelAdapterParser |
The parser for JPA outbound channel adapter
|
| JpaOutboundGateway |
The Jpa Outbound Gateway will allow you to make outbound operations to either:
submit (insert, delete) data to a database using JPA
retrieve (select) data from a database
Depending on the selected
OutboundGatewayType, the outbound gateway
will use either the JpaExecutor's poll method or its
executeOutboundJpaOperation method. |
| JpaOutboundGatewayFactoryBean |
The
JpaOutboundGatewayFactoryBean creates instances of the
JpaOutboundGateway. |
| JpaParameter |
Abstraction of Jpa parameters allowing to provide static parameters
and SpEl Expression based parameters.
|
| JpaParserUtils |
Contains various utility methods for parsing JPA Adapter specific namespace
elements and generation the respective
BeanDefinitions. |
| 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
After the objects have been polled, it also possibly to either:
executes an update after the select possibly to updated the state of selected records
executes an update (per retrieved object or for the entire payload)
delete the retrieved object
|
| JpaRetrievingOutboundGatewaySpec |
A
JpaBaseOutboundEndpointSpec extension for the
JpaOutboundGateway with
OutboundGatewayType.RETRIEVING mode. |
| JpaUpdatingOutboundEndpointSpec | |
| JpaUtils |
This Utility contains a sub-set of utility methods from the Spring Data JPA Project.
|
| JschProxyFactoryBean |
Spring-friendly factory bean to create Jsch
Proxy objects. |
| JschProxyFactoryBean.Type | |
| JsonHeaders |
Pre-defined names and prefixes to be used for setting and/or retrieving JSON
entries from/to Message Headers and other adapter, e.g.
|
| JsonInboundMessageMapper |
InboundMessageMapper implementation that maps incoming JSON messages
to a Message with the specified payload type. |
| JsonInboundMessageMapper.JsonMessageParser<P> | |
| JsonObjectMapper<N,P> |
Strategy interface to convert an Object to/from the JSON representation.
|
| JsonObjectMapperProvider |
Simple factory to provide JsonObjectMapper
instances based on jackson-databind lib in the classpath.
|
| JsonOutboundMessageMapper |
OutboundMessageMapper implementation the converts a Message to a JSON
string representation. |
| JsonPathUtils |
Utility class to
JsonPathUtils.evaluate(java.lang.Object, java.lang.String, com.jayway.jsonpath.Predicate...) a jsonPath on the provided object. |
| JsonPropertyAccessor |
A SpEL
PropertyAccessor that knows how to read properties from JSON objects. |
| JsonToObjectTransformer |
Transformer implementation that converts a JSON string payload into an instance of the
provided target Class.
|
| JsonToObjectTransformerParser | |
| Kafka |
Factory class for Apache Kafka components.
|
| KafkaChannelParser |
Parser for a channel backed by a Kafka topic.
|
| KafkaInboundChannelAdapterParser |
Parser for the inbound channel adapter.
|
| KafkaInboundChannelAdapterSpec<K,V> |
Spec for a polled Kafka inbound channel adapter.
|
| KafkaInboundGateway<K,V,R> |
Inbound gateway.
|
| KafkaInboundGatewayParser |
Inbound gateway parser.
|
| KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>> |
A
MessagingGatewaySpec implementation for the KafkaInboundGateway. |
| KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> |
A
ConcurrentMessageListenerContainer
configuration KafkaInboundGatewaySpec extension. |
| KafkaIntegrationHeaders |
Headers specifically for Spring Integration components.
|
| KafkaMessageDrivenChannelAdapter<K,V> |
Message-driven channel adapter.
|
| KafkaMessageDrivenChannelAdapter.ListenerMode |
The listener mode for the container, record or batch.
|
| KafkaMessageDrivenChannelAdapterParser |
Parser for the message driven channel adapter.
|
| KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>> |
A
MessageProducerSpec implementation for the KafkaMessageDrivenChannelAdapter. |
| KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
A
ConcurrentMessageListenerContainer configuration
KafkaMessageDrivenChannelAdapterSpec extension. |
| KafkaMessageListenerContainerSpec<K,V> |
A helper class in the Builder pattern style to delegate options to the
ConcurrentMessageListenerContainer. |
| KafkaMessageSource<K,V> |
Polled message source for kafka.
|
| KafkaMessageSource.KafkaAckCallback<K,V> |
AcknowledgmentCallback for Kafka.
|
| KafkaMessageSource.KafkaAckCallbackFactory<K,V> |
AcknowledgmentCallbackFactory for KafkaAckInfo.
|
| KafkaMessageSource.KafkaAckInfo<K,V> |
Information for building an KafkaAckCallback.
|
| KafkaNamespaceHandler |
The namespace handler for the Kafka namespace.
|
| KafkaOutboundChannelAdapterParser |
Parser for the outbound channel adapter.
|
| KafkaOutboundGatewayParser |
Parser for the outbound gateway.
|
| KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> |
A
MessageHandlerSpec
implementation for the KafkaProducerMessageHandler
as a gateway. |
| KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> |
A
KafkaTemplate-based KafkaProducerMessageHandlerSpec extension. |
| KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R> |
An
IntegrationComponentSpec
implementation for the KafkaTemplate. |
| KafkaParsingUtils |
Utilities to assist with parsing XML.
|
| KafkaPointToPointChannelSpec |
Spec for a point to point channel backed by a Kafka topic.
|
| KafkaPollableChannelSpec |
Spec for a pollable channel.
|
| KafkaProducerMessageHandler<K,V> |
Kafka Message Handler; when supplied with a
ReplyingKafkaTemplate it is used as
the handler in an outbound gateway. |
| KafkaProducerMessageHandler.ProducerRecordCreator<K,V> |
Creates a
ProducerRecord from a Message and/or properties
derived from configuration and/or the message. |
| KafkaProducerMessageHandlerSpec<K,V,S extends KafkaProducerMessageHandlerSpec<K,V,S>> |
A
MessageHandlerSpec implementation for the KafkaProducerMessageHandler. |
| KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
A
KafkaTemplate-based KafkaProducerMessageHandlerSpec extension. |
| KafkaPublishSubscribeChannelSpec |
Spec for a publish/subscribe channel backed by a Kafka topic.
|
| KafkaSendFailureException |
An exception that is the payload of an
ErrorMessage when a send fails. |
| KafkaSubscribableChannelSpec<C extends SubscribableKafkaChannel> |
Spec for a subscribable channel.
|
| KafkaTemplateSpec<K,V> |
An
IntegrationComponentSpec implementation for the KafkaTemplate. |
| KotlinScriptExecutor |
An
AbstractScriptExecutor for the Kotlin scripts support. |
| KryoClassListRegistrar |
A
KryoRegistrar used to validateRegistration a
list of Java classes. |
| KryoClassMapRegistrar |
A
KryoRegistrar implementation backed by a Map
used to explicitly set the registration ID for each class. |
| KryoRegistrar |
Strategy interface used by
PojoCodec to configure registrations
classes consistently across Kryo instances. |
| KryoRegistrationRegistrar |
A
KryoRegistrar implementation backed by a List of Registration. |
| LambdaMessageProcessor |
The
MessageProcessor implementation for method invocation on the single method classes
- functional interface implementations. |
| LastModifiedFileListFilter |
The
FileListFilter implementation to filter those files which
File.lastModified() is less than the LastModifiedFileListFilter.age in comparison
with the current time. |
| LeaderEventPublisher |
Interface for publishing leader based application events.
|
| LeaderInitiator |
Bootstrap leadership
candidates
with ZooKeeper/Curator. |
| LeaderInitiatorFactoryBean |
Creates a
LeaderInitiator. |
| LeaderListenerParser | |
| LinkNode |
Represents a link between nodes.
|
| LinkNode.Type | |
| ListenableMetadataStore |
ConcurrentMetadataStore with the ability of registering MetadataStoreListener callbacks, to be
invoked when changes occur in the metadata store. |
| LoadBalancingChannelSpec<S extends MessageChannelSpec<S,C>,C extends AbstractMessageChannel> | |
| LoadBalancingStrategy |
Strategy for determining the iteration order of a MessageHandler list.
|
| LockRegistry |
Strategy for maintaining a registry of shared locks
|
| LockRegistryLeaderInitiator |
Component that initiates leader election based on holding a lock.
|
| LockRepository |
Encapsulation of the SQL shunting that is needed for locks.
|
| Log4j2LevelAdjuster |
A JUnit method
Rule that changes the Log4J 2 logger level for a set of classes
or packages while a test method is running. |
| LoggingChannelAdapterParser |
Parser for the 'logging-channel-adapter' element.
|
| LoggingHandler |
MessageHandler implementation that simply logs the Message or its payload depending on the value of the
'shouldLogFullMessage' or SpEL 'logExpression' property.
|
| LoggingHandler.Level | |
| LogLevels |
Test classes annotated with this will change logging levels between tests.
|
| LogLevelsCondition |
JUnit condition that adjusts and reverts log levels before/after each test.
|
| LongRunningIntegrationTest |
Rule to prevent long running tests from running on every build; set environment
variable RUN_LONG_INTEGRATION_TESTS on a CI nightly build to ensure coverage.
|
| LongRunningTest |
JUnit Jupiter condition to prevent long running tests from running on every build;
set environment variable
RUN_LONG_INTEGRATION_TESTS on a CI nightly build to ensure coverage. |
|
The factory for Spring Integration Mail components.
|
|
| MailHeaderEnricherParser | |
| MailHeaders |
Pre-defined header names to be used for setting and/or retrieving Mail
Message attributes from/to integration Message Headers.
|
| MailHeadersBuilder |
The Mail specific
MapBuilder implementation. |
| MailInboundChannelAdapterParser |
Parser for the <inbound-channel-adapter> element of Spring Integration's 'mail' namespace.
|
| MailInboundChannelAdapterSpec<S extends MailInboundChannelAdapterSpec<S,R>,R extends AbstractMailReceiver> | |
| MailIntegrationEvent | |
| MailNamespaceHandler |
Namespace handler for the 'mail' namespace.
|
| MailOutboundChannelAdapterParser |
Parser for the <outbound-channel-adapter/> element of the 'mail' namespace.
|
| MailReceiver |
Strategy interface for receiving mail
Messages. |
| MailReceiverFactoryBean | |
| MailReceivingMessageSource |
MessageSource implementation that
delegates to a MailReceiver to poll a mailbox. |
| MailSendingMessageHandler |
A
MessageHandler implementation for sending mail. |
| MailSendingMessageHandlerSpec | |
| MailToStringTransformer |
Transforms a Message payload of type
Message to a String. |
| MailToStringTransformerParser |
Parser for the <mail-to-string-transformer> element.
|
| MailTransportUtils |
Collection of utility methods to work with Mail transports.
|
| MailUtils |
Utilities for handling mail messages.
|
| ManageableLifecycle |
Makes
Lifecycle methods manageable. |
| ManageableSmartLifecycle |
Extend
ManageableLifecycle to make those methods manageable. |
| ManagedEndpoint | Deprecated.
this is no longer used by the framework.
|
| ManualAckListenerExecutionFailedException |
A
ListenerExecutionFailedException enhanced with the channel and delivery tag. |
| MapArgumentResolver |
A
HandlerMethodArgumentResolver implementation to resolve argument
for the MethodParameter as a Map or Properties. |
| MapBuilder<B extends MapBuilder<B,K,V>,K,V> |
A
Builder pattern implementation for the Map. |
| MapContentMatchers<T,V> |
Matchers that examine the contents of a
Map. |
| MapJsonSerializer |
Serializes a
Map as JSON. |
| MapMessageConverter |
Converts to/from a Map with 2 keys ('headers' and 'payload').
|
| MappingMessageRouterManagement |
Exposes channel mapping operations when the router is proxied.
|
| MappingUtils |
Utility methods used during message mapping.
|
| MapToObjectTransformer |
Will transform Map to an instance of Object.
|
| MapToObjectTransformerParser | |
| MarshallingTransformer |
An implementation of
AbstractTransformer that delegates
to an OXM Marshaller. |
| MarshallingTransformerParser | |
| MarshallingWebServiceInboundGateway | |
| MarshallingWebServiceOutboundGateway |
An outbound Messaging Gateway for invoking Web Services that also supports
marshalling and unmarshalling of the request and response messages.
|
| MarshallingWsInboundGatewaySpec |
The spec for a
MarshallingWebServiceInboundGateway. |
| MarshallingWsOutboundGatewaySpec |
The spec for a
MarshallingWebServiceOutboundGateway. |
| MarshallingWsOutboundGatewaySpec.MarshallingWsOutboundGatewayNoTemplateSpec |
Spec for a
MarshallingWebServiceOutboundGateway where an external
WebServiceTemplate is not provided. |
| MBeanAttributeFilter | |
| MBeanExporterParser |
Parser for the 'mbean-export' element of the integration JMX namespace.
|
| MBeanObjectConverter | |
| MBeanTreePollingChannelAdapterParser | |
| MBeanTreePollingMessageSource |
A
MessageSource implementation that
retrieves a snapshot of a filtered subset of the MBean tree. |
| MessageBuilder<T> |
The default message builder; creates immutable
GenericMessages. |
| MessageBuilderFactory | |
| MessageChannelNode |
Represents a message channel.
|
| MessageChannelReactiveUtils | Deprecated.
since 5.3 in favor of
IntegrationReactiveUtils. |
| MessageChannelReference |
An "artificial"
MessageChannel implementation which will be unwrapped to the
MessageChannel bean on the bean registration phase. |
| MessageChannels | |
| MessageChannelSpec<S extends MessageChannelSpec<S,C>,C extends AbstractMessageChannel> | |
| MessageCodec |
PojoCodec configured to encode/decode Message<?>s. |
| MessageCollectionCallback<T> |
The callback to be used with the
MongoDbOutboundGateway
as an alternative to other query options on the gateway. |
| MessageConverter |
A converter to convert the raw message created by the underlying
UDP/TCP endpoint to a specific form of Syslog message.
|
| MessageConvertingTcpMessageMapper | |
| MessageCountReleaseStrategy | |
| MessageDecorator |
The
Message decoration contract. |
| MessageDispatcher |
Strategy interface for dispatching messages to handlers.
|
| MessageDispatchingException |
Exception that indicates an internal error occurred within a
MessageDispatcher
preventing message delivery. |
| MessageDocument |
The entity class to wrap
Message to the MongoDB document. |
| MessageDocumentFields | |
| MessageEndpoint |
Stereotype annotation indicating that a class is capable of serving as a
Message Endpoint.
|
| MessageFilter |
Message Handler that delegates to a
MessageSelector. |
| MessageGatewayNode |
Represents an inbound gateway.
|
| MessageGroup |
A group of messages that are correlated with each other and should be processed in the same context.
|
| MessageGroupExpiredEvent |
Event representing the expiration of a message group.
|
| MessageGroupFactory |
The
MessageGroup factory strategy. |
| MessageGroupMetadata |
Value Object holding metadata about a MessageGroup in the MessageGroupStore.
|
| MessageGroupProcessor |
A processor for correlated groups of messages.
|
| MessageGroupQueue |
A
BlockingQueue that is backed by a MessageGroupStore. |
| MessageGroupStore |
Defines additional storage operations on groups of messages linked by a group id.
|
| MessageGroupStore.MessageGroupCallback |
Invoked when a MessageGroupStore expires a group.
|
| MessageGroupStoreReaper |
Convenient configurable component to allow explicit timed expiry of
MessageGroup instances in a
MessageGroupStore. |
| MessageHandlerChain |
A composite
MessageHandler implementation that invokes a chain of
MessageHandler instances in order. |
| MessageHandlerNode |
Represents a message handler.
|
| MessageHandlerSpec<S extends MessageHandlerSpec<S,H>,H extends MessageHandler> |
An
IntegrationComponentSpec for MessageHandlers. |
| MessageHandlerSupport |
Base class for Message handling components that provides basic validation and error
handling capabilities.
|
| MessageHandlingTaskDecorator |
The strategy to decorate
MessageHandlingRunnable tasks
to be used with the Executor. |
| MessageHeadersJacksonSerializer | |
| MessageHistory | |
| MessageHistory.Entry |
Inner class for each Entry in the history.
|
| MessageHistoryConfigurer | |
| MessageHistoryParser |
The
<message-history/> parser. |
| MessageHistoryRegistrar | |
| MessageHolder |
The
MessageStore specific value object to keep the Message and its metadata. |
| MessageJacksonDeserializer<T extends Message<?>> |
A Jackson
StdNodeBasedDeserializer extension for Message implementations. |
| MessageKryoRegistrar |
Registers common MessageHeader types and Serializers.
|
| MessageListProcessor | |
| MessageMappingException |
Exception that indicates an error during message mapping.
|
| MessageMatcher |
Matcher to make assertions about message equality easier.
|
| MessageMetadata |
Value Object holding metadata about a Message in the MessageStore.
|
| MessagePredicate |
Predicate to make assertions about message equality easier.
|
| MessagePreparedStatementSetter |
The callback to be used with the
JdbcMessageHandler
as an alternative to the SqlParameterSourceFactory. |
| MessageProcessingHeaderValueMessageProcessor | |
| MessageProcessor<T> |
This defines the lowest-level strategy of processing a Message and returning
some Object (or null).
|
| MessageProcessorMessageSource |
The
MessageSource strategy implementation
to produce a Message from underlying
MessageProcessorMessageSource.messageProcessor for polling endpoints. |
| MessageProcessorSpec<S extends MessageProcessorSpec<S>> |
The
IntegrationComponentSpec specific base class
for MessageProcessors. |
| MessageProducer |
Base interface for any component that is capable of sending
messages to a
MessageChannel. |
| MessageProducerNode |
Represents an inbound message producer.
|
| MessageProducerSpec<S extends MessageProducerSpec<S,P>,P extends MessageProducerSupport> |
An
IntegrationComponentSpec for
MessageProducers. |
| MessageProducerSupport |
A support class for producer endpoints that provides a setter for the
output channel and a convenience method for sending Messages.
|
| MessagePublishingErrorHandler | |
| MessagePublishingInterceptor |
A
MethodInterceptor that publishes Messages to a channel. |
| MessageRejectedException |
Exception that indicates a message has been rejected by a selector.
|
| MessageRouter |
Routers implementing this interface have a default output channel.
|
| MessageRowMapper |
Convenience class to be used to unpack a
Message from a result set
row. |
| MessageSelectingInterceptor |
A
ChannelInterceptor that
delegates to a list of MessageSelectors to decide
whether a Message should be accepted on the MessageChannel. |
| MessageSelector |
Strategy interface for message selection.
|
| MessageSelectorChain |
A message selector implementation that passes incoming messages through a
chain of selectors.
|
| MessageSelectorChain.VotingStrategy | |
| MessageSequenceComparator | |
| MessageSessionCallback<F,T> |
Callback invoked by
RemoteFileOperations.executeForMessage()
- allows multiple operations on a session. |
| MessageSource<T> |
Base interface for any source of
Messages that can be polled. |
| MessageSourceManagement |
Message sources implementing this interface have additional properties that
can be set or examined using JMX.
|
| MessageSourceMutator |
A
ReceiveMessageAdvice extension that can mutate a MessageSource before and/or after
MessageSource.receive() is called. |
| MessageSourceNode |
Represents a message source.
|
| MessageSourcePollingTemplate |
A
PollingOperations used to ad-hoc poll a MessageSource. |
| MessageSourceSpec<S extends MessageSourceSpec<S,H>,H extends MessageSource<?>> |
An
IntegrationComponentSpec for MessageSources. |
| MessageStore |
Strategy interface for storing and retrieving messages.
|
| MessageStoreException |
Exception for problems that occur when using a
MessageStore implementation. |
| MessageTimeoutException |
Exception that indicates a timeout elapsed prior to successful message delivery.
|
| MessageToBinaryConverter | |
| MessageTransformationException |
Base Exception type for Message transformation errors.
|
| MessageTransformingHandler |
A reply-producing
MessageHandler
that delegates to a Transformer instance to modify the received Message
and sends the result to its output channel. |
| MessageTriggerAction |
Classes implementing this interface can take some action when a trigger
Message
is received. |
| MessageValidator |
Validate a message.
|
| MessagingAnnotationPostProcessor |
A
BeanPostProcessor implementation that processes method-level
messaging annotations such as @Transformer, @Splitter, @Router, and @Filter. |
| MessagingAnnotationUtils |
Utility methods to support annotation processing.
|
| MessagingEvent |
A subclass of
ApplicationEvent that wraps a Message. |
| MessagingExceptionWrapper |
A wrapper exception for a
MessagingException used to convey the cause and
original message to a
MessagePublishingErrorHandler. |
| MessagingGateway |
A stereotype annotation to provide an Integration Messaging Gateway Proxy
(
<gateway/>) as an abstraction over the messaging API. |
| MessagingGatewayRegistrar |
The
ImportBeanDefinitionRegistrar to parse MessagingGateway and its service-interface
and to register BeanDefinition GatewayProxyFactoryBean. |
| MessagingGatewaySpec<S extends MessagingGatewaySpec<S,G>,G extends MessagingGatewaySupport> | |
| MessagingGatewaySupport |
A convenient base class for connecting application code to
MessageChannels for sending, receiving, or request-reply operations. |
| MessagingMethodInvokerHelper |
A helper class for processors that invoke a method on a target Object using
a combination of message payload(s) and headers as arguments.
|
| MessagingMethodInvokerHelper.ParametersWrapper | |
| MessagingTemplate | |
| MetadataStore |
Strategy interface for storing metadata from certain adapters
to avoid duplicate delivery of messages, for example.
|
| MetadataStoreListener |
A callback to be invoked whenever a value changes in the data store.
|
| MetadataStoreListenerAdapter |
Base implementation for a
MetadataStoreListener. |
| MetadataStoreSelector | |
| MeterFacade |
Facade for Meters.
|
| MethodAnnotationPostProcessor<T extends Annotation> |
Strategy interface for post-processing annotated methods.
|
| MethodAnnotationPublisherMetadataSource |
An
PublisherMetadataSource implementation that retrieves the channel
name and expression strings from an annotation. |
| MethodArgsHolder |
Simple wrapper class containing a
Method and an object
array containing the arguments for an invocation of that method. |
| MethodArgsMessageMapper |
Implementations of this interface are
InboundMessageMappers
that map a MethodArgsHolder to a Message. |
| MethodInvokingCorrelationStrategy |
CorrelationStrategy implementation that works as an adapter to another bean. |
| MethodInvokingMessageGroupProcessor |
MessageGroupProcessor that serves as an adapter for the invocation of a POJO method.
|
| MethodInvokingMessageHandler |
A
MessageHandler that invokes the specified
method on the provided object. |
| MethodInvokingMessageListProcessor<T> |
A MessageListProcessor implementation that invokes a method on a target POJO.
|
| MethodInvokingMessageProcessor<T> |
A MessageProcessor implementation that invokes a method on a target Object.
|
| MethodInvokingMessageSource |
A
MessageSource implementation that
invokes a no-argument method so that its return value may be sent to a channel. |
| MethodInvokingReleaseStrategy |
A
ReleaseStrategy that invokes a method on a plain old Java object. |
| MethodInvokingRouter |
A Message Router that invokes the specified method on the given object.
|
| MethodInvokingSelector |
A method-invoking implementation of
MessageSelector. |
| MethodInvokingSplitter |
A Message Splitter implementation that invokes the specified method
on the given object.
|
| MethodInvokingTransformer |
A Message Transformer implementation that invokes the specified method
on the given object.
|
| MethodNameMappingPublisherMetadataSource | |
| MetricsCaptor |
A metrics facade that delegates to a concrete implementation.
|
| MetricsCaptor.CounterBuilder |
A builder for a counter.
|
| MetricsCaptor.GaugeBuilder |
A builder for a gauge.
|
| MetricsCaptor.TimerBuilder |
A builder for a timer.
|
| MicrometerMetricsCaptor |
The Micrometer implementation of
MetricsCaptor. |
| MicrometerMetricsCaptor.AbstractMeter<M extends io.micrometer.core.instrument.Meter> | |
| MicrometerMetricsCaptor.MicroCounter | |
| MicrometerMetricsCaptor.MicroCounterBuilder | |
| MicrometerMetricsCaptor.MicroGauge | |
| MicrometerMetricsCaptor.MicroGaugeBuilder | |
| MicrometerMetricsCaptor.MicroTimer | |
| MicrometerMetricsCaptor.MicroTimerBuilder | |
| MicrometerMetricsCaptorRegistrar |
An
ImportBeanDefinitionRegistrar to conditionally add a MicrometerMetricsCaptor
bean when io.micrometer.core.instrument.MeterRegistry is present in classpath and
no MicrometerMetricsCaptor.MICROMETER_CAPTOR_NAME bean present yet. |
| MicrometerNodeEnhancer |
Add micrometer metrics to the node.
|
| MimeTypeSerializer |
Simple
StdSerializer extension to represent a MimeType object in the
target JSON as a plain string. |
| MockIntegration |
The factory for integration specific mock components.
|
| MockIntegrationContext |
A
BeanFactoryAware component with an API to customize real beans
in the application context from test code. |
| MockitoMessageMatchers |
Mockito matcher factory for
Message matcher creation. |
| MockMessageHandler |
The
AbstractMessageProducingHandler extension for the mocking purpose in tests. |
| MongoDb |
Factory class for building MongoDb components
|
| MongoDbChangeStreamMessageProducer |
A
MessageProducerSupport for MongoDB Change Stream implementation. |
| MongoDbChangeStreamMessageProducerSpec | |
| MongoDbChannelMessageStore |
MongoDB
PriorityCapableChannelMessageStore implementation. |
| MongoDbInboundChannelAdapterParser |
Parser for Mongodb store inbound adapters
|
| MongoDbMessageSource |
An instance of
MessageSource which returns
a Message with a payload which is the result of
execution of a Query. |
| MongoDbMessageStore |
An implementation of both the
MessageStore and
MessageGroupStore
strategies that relies upon MongoDB for persistence. |
| MongoDbMetadataStore |
MongoDbMetadataStore implementation of
ConcurrentMetadataStore. |
| MongoDbNamespaceHandler |
Namespace handler for Spring Integration's 'mongodb' namespace.
|
| MongoDbOutboundChannelAdapterParser |
Parser for Mongodb store outbound adapters
|
| MongoDbOutboundGateway |
Makes outbound operations to query a MongoDb database using a
MongoOperations |
| MongoDbOutboundGatewayParser |
Parser for MongoDb outbound gateways
|
| MongoDbOutboundGatewaySpec |
A
MessageHandlerSpec extension for the MongoDb Outbound endpoint MongoDbOutboundGateway |
| MongoDbStoringMessageHandler |
Implementation of
MessageHandler
which writes Message payload into a MongoDb collection
identified by evaluation of the MongoDbStoringMessageHandler.collectionNameExpression. |
| MongoHeaders |
Pre-defined names and prefixes to be used for
for dealing with headers required by Mongo components
|
| MqttComponent<T> |
A component that interfaces with MQTT.
|
| MqttConnectionFailedEvent | |
| MqttHeaderAccessor |
Helper for typed access to incoming MQTT message headers.
|
| MqttHeaders |
Spring Integration headers.
|
| MqttIntegrationEvent |
Base class for Mqtt Events.
|
| MqttMessageConverter |
Extension of
MessageConverter allowing the topic to be added as
a header. |
| MqttMessageDeliveredEvent |
An event emitted (when using aysnc) when the client indicates the message
was delivered.
|
| MqttMessageDeliveryEvent |
Base class for events related to message delivery.
|
| MqttMessageDrivenChannelAdapterParser |
The MqttAdapter Message Driven Channel adapter parser
|
| MqttMessageSentEvent |
An event emitted (when using aysnc) when the client indicates that a message
has been sent.
|
| MqttNamespaceHandler |
The namespace handler for the MqttAdapter namespace
|
| MqttOutboundChannelAdapterParser |
The parser for the MqttAdapter Outbound Channel Adapter.
|
| MqttPahoClientFactory | |
| MqttPahoComponent |
An extension of
MqttComponent for Eclipse Paho components. |
| MqttPahoMessageDrivenChannelAdapter |
Eclipse Paho Implementation.
|
| MqttPahoMessageHandler |
Eclipse Paho Implementation.
|
| MqttSubscribedEvent | |
| MqttUtils |
MQTT Utilities
|
| MulticastReceivingChannelAdapter |
Channel adapter that joins a multicast group and receives incoming packets and
sends them to an output channel.
|
| MulticastSendingMessageHandler |
A
MessageHandler implementation that maps a
Message into a UDP datagram packet and sends that to the specified multicast address
(224.0.0.0 to 239.255.255.255) and port. |
| MultipartAwareFormHttpMessageConverter |
An
HttpMessageConverter implementation that delegates to an instance of
AllEncompassingFormHttpMessageConverter while adding the capability to read
multipart/form-data content in an HTTP request. |
| MultipartFileReader<T> |
Strategy for reading
MultipartFile content. |
| MultipartHttpInputMessage | |
| MutableMessage<T> |
An implementation of
Message with a generic payload. |
| MutableMessageBuilder<T> |
Specialized message builder that can be used within a component to avoid the overhead
of having to build multiple messages for mutations within that component.
|
| MutableMessageBuilderFactory | |
| MutableMessageHeaders |
A MessageHeaders that permits direct access to and modification of the
header map.
|
| MutableMessageJacksonDeserializer |
The
MessageJacksonDeserializer implementation for the MutableMessage. |
| MySqlChannelMessageStoreQueryProvider | |
| NackedAmqpMessageException |
An exception representing a negatively acknowledged message from a
publisher confirm.
|
| NamedComponent | |
| NamedFieldsMBeanAttributeFilter | |
| NioFileLocker |
File locking strategy that uses java.nio.
|
| NoListenerException | |
| NotificationListeningChannelAdapterParser | |
| NotificationListeningMessageProducer |
A JMX
NotificationListener implementation that will send Messages
containing the JMX Notification instances as their payloads. |
| NotificationPublishingChannelAdapterParser | |
| NotificationPublishingMessageHandler |
An
AbstractMessageHandler implementation to publish an incoming message
as a JMX Notification. |
| NotificationPublishingMessageHandler.PublisherDelegate |
Simple class used for the actual MBean instances to be registered.
|
| NotNamedFieldsMBeanAttributeFilter | |
| NullAwarePayloadArgumentResolver |
A
PayloadMethodArgumentResolver that treats KafkaNull payloads as null. |
| NullChannel |
A channel implementation that essentially behaves like "/dev/null".
|
| ObjectStringMapBuilder |
A map builder creating a map with Object keys and String values.
|
| ObjectStringMessageConverter |
A
StringMessageConverter extension to convert any object to string. |
| ObjectToJsonTransformer |
Transformer implementation that converts a payload instance into a JSON string
representation.
|
| ObjectToJsonTransformer.ResultType | |
| ObjectToJsonTransformerParser | |
| ObjectToMapTransformer |
Transforms an object graph into a Map.
|
| ObjectToMapTransformerParser | |
| ObjectToStringTransformer |
A simple transformer that creates an outbound payload by invoking the
inbound payload Object's
toString() method. |
| ObjectToStringTransformerParser |
Parser for the 'object-to-string-transformer' element.
|
| OnFailedToAcquireMutexEvent |
Generic event representing that a mutex could not be acquired during leader election.
|
| OnGrantedEvent |
Generic event representing that leader has been granted.
|
| OnlyOnceTrigger | |
| OnRevokedEvent |
Generic event representing that leader has been revoked.
|
| OperationInvokingChannelAdapterParser | |
| OperationInvokingMessageHandler |
A
MessageHandler implementation for invoking JMX operations based on
the Message sent to its AbstractMessageHandler.handleMessage(Message) method. |
| OperationInvokingOutboundGatewayParser | |
| OracleChannelMessageStoreQueryProvider |
Contains Oracle-specific queries for the
JdbcChannelMessageStore. |
| Orderable |
Interface that extends
Ordered while also exposing the
Orderable.setOrder(int) as an interface-level so that it is avaiable
on AOP proxies, etc. |
| OrderlyShutdownCapable |
Interface for components that wish to be considered for
an orderly shutdown using management interfaces.
|
| OSDelegatingFileTailingMessageProducer |
A file tailing message producer that delegates to the OS tail program.
|
| OutboundGatewayType |
Indicates the mode of operation for the outbound Jpa Gateway.
|
| OutboundMessageMapper<T> |
Strategy interface for mapping from a
Message to an Object. |
| ParameterSource | |
| ParameterSourceFactory | |
| PartialSuccessException |
A
MessagingException thrown when a non-transactional operation is
performing multiple updates from a single message, e.g. |
| PassThroughTransactionSynchronizationFactory |
A simple
TransactionSynchronizationFactory implementation which produces
an IntegrationResourceHolderSynchronization with an IntegrationResourceHolder. |
| PassThruLockRegistry |
The
LockRegistry implementation which has no effect. |
| PassThruMessageConverter |
The simple
MessageConverter implementation which contract is to return
Message as is for both from/to operations. |
| PassThruSubProtocolHandler |
The simple 'pass thru'
SubProtocolHandler, when there is no interests in the
WebSocket sub-protocols. |
| PathMovedEvent |
An event emitted when a path is moved.
|
| PathMovedEvent |
An event emitted when a path is moved.
|
| PathRemovedEvent |
An event emitted when a file or directory is removed.
|
| PathRemovedEvent |
An event emitted when a file or directory is removed.
|
| PatternMatchUtils |
Utility methods for pattern matching.
|
| Pausable |
Endpoints implementing this interface can be paused/resumed.
|
| PayloadAndHeaderMatcher<T> |
Matcher to make assertions about message equality easier.
|
| PayloadDeserializingTransformer |
Transformer that deserializes the inbound byte array payload to an object by delegating
to a Converter<byte[], Object>.
|
| PayloadDeserializingTransformerParser |
Parser for the 'payload-deserializing-transformer' element.
|
| PayloadExpressionArgumentResolver |
The
HandlerMethodArgumentResolver for evaluating Payload.expression()
as a SpEL expression against message and converting result to expected parameter type. |
| PayloadMatcher<T> |
Is the payload of a
Message equal to a given value or is matching
a given matcher? |
| Payloads |
This annotation marks a method parameter as being a list of message payloads, for POJO handlers that deal with lists
of messages (e.g.
|
| PayloadsArgumentResolver |
The
HandlerMethodArgumentResolver for resolving a Collection
of payloads or expression against each payload. |
| PayloadSerializingTransformer |
Transformer that serializes the inbound payload into a byte array by delegating to a
Converter<Object, byte[]>.
|
| PayloadSerializingTransformerParser |
Parser for the 'payload-serializing-transformer' element.
|
| PayloadTypeConvertingTransformer<T,U> |
Transformer that converts the inbound payload to an object by delegating to a
Converter<Object, Object>.
|
| PayloadTypeRouter |
A Message Router that resolves the
MessageChannel
based on the Message's payload type. |
| PayloadTypeRouterParser |
Parser for the <payload-type-router/> element.
|
| PayloadTypeSelector |
A
MessageSelector implementation that checks the type of the
Message payload. |
| PayloadValidator<T> |
Validate a message payload.
|
| PersistMode |
Indicates how entities shall be persisted to the underlying persistence store.
|
| PointToPointChannelParser |
Parser for the <channel> element.
|
| PointToPointSubscribableAmqpChannel | |
| PojoCodec |
Kryo Codec that can encode and decode arbitrary types.
|
| PollableAmqpChannel |
A
PollableChannel implementation that is backed by an AMQP Queue. |
| PollableChannelNode |
Represents a pollable channel.
|
| PollableJmsChannel | |
| PollableKafkaChannel |
Pollable channel backed by a Kafka topic.
|
| Poller |
Provides the
PollerMetadata options
for the Messaging annotations for polled endpoints. |
| PollerFactory |
An
Adapter class for the Pollers factory. |
| PollerMetadata | |
| PollerParser |
Parser for the <poller> element.
|
| Pollers |
An utility class to provide
PollerSpecs for
PollerMetadata configuration
variants. |
| PollerSpec |
An
IntegrationComponentSpec for PollerMetadatas. |
| PollingConsumer |
Message Endpoint that connects any
MessageHandler implementation
to a PollableChannel. |
| PollingOperations |
Operations to perform on some message source.
|
| PollSkipAdvice |
An advice that can be added to a poller's advice chain that determines
whether a poll should be skipped or not.
|
| PollSkipStrategy |
Implementations determine whether a particular poll should be skipped.
|
| Pool<T> |
Represents a pool of items.
|
| PoolItemNotAvailableException |
Thrown when a pooled item could not be obtained for some reason.
|
| Pop3MailInboundChannelAdapterSpec |
A
MailInboundChannelAdapterSpec for POP3. |
| Pop3MailReceiver |
A
MailReceiver implementation that polls a mail server using the
POP3 protocol. |
| PositionSupportingParameterSource | |
| PostgresChannelMessageStoreQueryProvider | |
| PostProcessingMessageHandler |
Implementations of this interface are subclasses of
AbstractMessageHandler that perform post processing after the
AbstractMessageHandler.handleMessageInternal(org.springframework.messaging.Message)
call. |
| PresenceInboundChannelAdapterParser |
Parser for 'xmpp:presence-inbound-channel-adapter' element.
|
| PresenceListeningEndpoint |
An inbound endpoint that is able to login and then emit
particular Presence event occurs within the logged-in user's
Roster. |
| PresenceOutboundChannelAdapterParser |
Parser for 'xmpp:presence-outbound-channel-adapter' element
|
| PresenceSendingMessageHandler |
MessageHandler that publishes updated Presence values for a given XMPP connection.
|
| PriorityCapableChannelMessageStore |
A
ChannelMessageStore that supports the
notion of message priority. |
| PriorityChannel |
A message channel that prioritizes messages based on a
Comparator. |
| PriorityChannelSpec | |
| ProcedureParameter |
Abstraction of Procedure parameters allowing to provide static parameters
and SpEl Expression based parameters.
|
| PropertiesBuilder |
A
Builder pattern implementation for the Properties. |
| PropertiesPersistingMetadataStore |
Properties file-based implementation of
MetadataStore. |
| PseudoTransactionManager |
An implementation of
PlatformTransactionManager
that provides transaction-like semantics to
MessageSources that are not inherently
transactional. |
| Publisher |
Annotation to indicate that a method, or all public methods if applied at class-level,
should publish Messages.
|
| PublisherAnnotationAdvisor |
An advisor that will apply the
MessagePublishingInterceptor to any
methods containing the provided annotations. |
| PublisherAnnotationBeanPostProcessor |
Post-processes beans that contain the
method-level @
Publisher annotation. |
| PublisherRegistrar | |
| PublishingInterceptorParser |
Parser for the <publishing-interceptor> element.
|
| PublishSubscribeAmqpChannel |
The
AbstractSubscribableAmqpChannel extension for pub-sub semantics based on the FanoutExchange. |
| PublishSubscribeChannel |
A channel that sends Messages to each of its subscribers.
|
| PublishSubscribeChannelParser |
Parser for the <publish-subscribe-channel> element.
|
| PublishSubscribeChannelSpec<S extends PublishSubscribeChannelSpec<S>> | |
| PublishSubscribeKafkaChannel |
Publish/subscribe channel backed by a Kafka topic.
|
| PublishSubscribeSpec |
The
PublishSubscribeChannelSpec extension to configure as a general flow callback for sub-flows
as subscribers. |
| PythonScriptExecutor |
A
ScriptExecutor
that implements special handling required for Python to
emulate behavior similar to other JSR223 scripting languages. |
| PythonScriptExecutor.PythonVariableParser | |
| QueueChannel |
Simple implementation of a message channel.
|
| QueueChannelOperations |
Operations available on a channel that has queuing semantics.
|
| QueueChannelSpec | |
| QueueChannelSpec.MessageStoreSpec |
The
ChannelMessageStore-specific QueueChannelSpec extension. |
| R2dbc |
Java DSL Factory class for R2DBC components.
|
| R2dbcMessageHandler |
Implementation of
ReactiveMessageHandler which writes
Message payload into a Relational Database, using reactive r2dbc support. |
| R2dbcMessageHandler.Type |
/**
The mode for the
R2dbcMessageHandler. |
| R2dbcMessageHandlerSpec |
The
ReactiveMessageHandlerSpec for the R2dbcMessageHandler. |
| R2dbcMessageSource |
An instance of
MessageSource which returns
a Message with a payload which is the result of
execution of query. |
| R2dbcMessageSourceSpec |
The
MessageSourceSpec for the R2dbcMessageSource. |
| RateLimiterRequestHandlerAdvice |
An
AbstractRequestHandlerAdvice extension for a rate limiting to service method calls. |
| RateLimiterRequestHandlerAdvice.RateLimitExceededException |
A
MessagingException wrapper for the RequestNotPermitted
with the requestMessage and target context. |
| RawRecordHeaderErrorMessageStrategy |
ErrorMessageStrategy extension that adds the raw record as
a header to the ErrorMessage. |
| ReactiveMessageHandlerAdapter |
A
MessageHandler implementation to adapt a ReactiveMessageHandler
for synchronous invocations. |
| ReactiveMessageHandlerSpec<S extends ReactiveMessageHandlerSpec<S,H>,H extends ReactiveMessageHandler> |
The
MessageHandlerSpec extension for ReactiveMessageHandler. |
| ReactiveMessageSourceProducer |
The
MessageProducerSupport to adapt a provided MessageSource
into a Flux and let it be subscribed in the MessageProducerSupport.subscribeToPublisher(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>>) |
| ReactiveMongoDbMessageHandlerSpec |
A
ReactiveMessageHandlerSpec extension for the Reactive MongoDb Outbound endpoint
ReactiveMongoDbStoringMessageHandler. |
| ReactiveMongoDbMessageSource |
An instance of
MessageSource which returns
a Message with a payload which is the result of
execution of a Query. |
| ReactiveMongoDbMessageSourceSpec |
A
MessageSourceSpec implementation for a ReactiveMongoDbMessageSource. |
| ReactiveMongoDbStoringMessageHandler |
Implementation of
ReactiveMessageHandler which writes
Message payload into a MongoDb collection, using reactive MongoDb support, The
collection is identified by evaluation of the ReactiveMongoDbStoringMessageHandler.collectionNameExpression. |
| ReactiveRedisStreamMessageHandler |
Implementation of
ReactiveMessageHandler which writes
Message payload or Message itself (see ReactiveRedisStreamMessageHandler.extractPayload) into a Redis stream using Reactive Stream operations. |
| ReactiveRedisStreamMessageProducer |
A
MessageProducerSupport for reading messages from a Redis Stream and publishing them into the provided
output channel. |
| ReactiveRequestHandlerAdvice |
A
MethodInterceptor for message handlers producing a Mono as a payload for reply. |
| ReactiveStreamsConsumer |
An
AbstractEndpoint implementation for Reactive Streams subscription into an
input channel and reactive consumption of messages from that channel. |
| ReactiveStreamsSubscribableChannel | |
| ReactorNettyTcpStompSessionManager |
The
ReactorNettyTcpStompClient based AbstractStompSessionManager implementation. |
| ReceiptEvent |
The
AbstractSubProtocolEvent implementation, which is emitted
for the WebSocket sub-protocol-specific RECEIPT frame on the client side. |
| ReceiveCounters |
Counters for components that maintain receive counters.
|
| ReceiveCountersAware | |
| ReceiveMessageAdvice |
An AOP advice to perform hooks before and/or after a
receive() contract is called. |
| RecipientListRouter |
<recipient-list-router id="simpleRouter" input-channel="routingChannelA">
<recipient channel="channel1"/>
<recipient channel="channel2"/>
</recipient-list-router>
|
| RecipientListRouter.Recipient | |
| RecipientListRouterManagement |
Exposes adding/removing individual recipients operations for
RecipientListRouter.
|
| RecipientListRouterParser |
Parser for the <recipient-list-router/> element.
|
| RecipientListRouterSpec |
An
AbstractRouterSpec for a RecipientListRouter. |
| RecursiveDirectoryScanner |
The
DefaultDirectoryScanner extension which walks through the directory tree
using Files.walk(Path, int, FileVisitOption...). |
| RedisChannelMessageStore |
Specialized Redis
ChannelMessageStore that uses a list to back a QueueChannel. |
| RedisChannelParser |
Parser for the 'channel' and 'publish-subscribe-channel' elements of the
Spring Integration Redis namespace.
|
| RedisChannelPriorityMessageStore |
Specialized Redis
PriorityCapableChannelMessageStore that uses lists to back a QueueChannel. |
| RedisExceptionEvent | |
| RedisHeaders |
Pre-defined names and prefixes to be used for
for dealing with headers required by Redis components
|
| RedisInboundChannelAdapter | |
| RedisInboundChannelAdapterParser | |
| RedisIntegrationEvent | |
| RedisLockRegistry |
Implementation of
ExpirableLockRegistry providing a distributed lock using Redis. |
| RedisMessageStore |
Redis implementation of the key/value style
MessageStore and
MessageGroupStore |
| RedisMetadataStore |
Redis implementation of
ConcurrentMetadataStore. |
| RedisNamespaceHandler |
Namespace handler for Spring Integration's 'redis' namespace.
|
| RedisOutboundChannelAdapterParser |
Parser for the
<outbound-channel-adapter/> component. |
| RedisOutboundGateway |
The Gateway component implementation to perform Redis commands with provided arguments and to return command result.
|
| RedisOutboundGatewayParser |
Parser for the
<int-redis:outbound-gateway/> component. |
| RedisPublishingMessageHandler | |
| RedisQueueInboundChannelAdapterParser |
Parser for the <queue-inbound-channel-adapter> element of the 'redis' namespace.
|
| RedisQueueInboundGateway | |
| RedisQueueInboundGatewayParser |
Parser for the <queue-inbound-gateway> element of the 'redis' namespace.
|
| RedisQueueMessageDrivenEndpoint | |
| RedisQueueOutboundChannelAdapter | |
| RedisQueueOutboundChannelAdapterParser |
Parser for the <int-redis:queue-outbound-channel-adapter> element.
|
| RedisQueueOutboundGateway | |
| RedisQueueOutboundGatewayParser |
Parser for the <int-redis:queue-outbound-channel-adapter> element.
|
| RedisStoreInboundChannelAdapterParser |
Parser for Redis store inbound adapters
|
| RedisStoreMessageSource |
Inbound channel adapter which returns a Message representing a view into
a Redis store.
|
| RedisStoreOutboundChannelAdapterParser |
Parser for the <redis:store-outbound-channel-adapter> element.
|
| RedisStoreWritingMessageHandler |
Implementation of
MessageHandler which writes
Message data into a Redis store identified by a key String. |
| RefreshableResourceScriptSource |
A
ScriptSource implementation, which caches a script string and refreshes it from the
target file (if modified) according the provided RefreshableResourceScriptSource.refreshDelay. |
| RegexPatternFileListFilter |
Implementation of AbstractRegexPatternMatchingFileListFilter for java.io.File instances.
|
| RegexTestXPathMessageSelector |
XPath
MessageSelector that tests if a
provided String value matches a given Regular Expression. |
| RegexUtils |
Regular Expression Utilities.
|
| RegistrationIds |
Default registration ids for serializers provided by the framework.
|
| ReleaseStrategy |
Strategy for determining when a group of messages reaches a state of
completion (i.e.
|
| ReleaseStrategy |
Indicates that a method is capable of asserting if a list of messages or
payload objects is complete.
|
| ReleaseStrategyFactoryBean |
Convenience factory for XML configuration of a
ReleaseStrategy. |
| ReloadableResourceBundleExpressionSource |
ExpressionSource implementation that accesses resource bundles using specified basenames. |
| RemoteFileInboundChannelAdapterSpec<F,S extends RemoteFileInboundChannelAdapterSpec<F,S,MS>,MS extends AbstractInboundFileSynchronizingMessageSource<F>> | |
| RemoteFileOperations<F> |
Strategy for performing operations on remote files.
|
| RemoteFileOperations.OperationsCallback<F,T> |
Callback for using the same session for multiple
RemoteFileTemplate operations.
|
| RemoteFileOutboundChannelAdapterParser | |
| RemoteFileOutboundGatewaySpec<F,S extends RemoteFileOutboundGatewaySpec<F,S>> |
The
MessageHandlerSpec for the AbstractRemoteFileOutboundGateway. |
| RemoteFileStreamingInboundChannelAdapterSpec<F,S extends RemoteFileStreamingInboundChannelAdapterSpec<F,S,MS>,MS extends AbstractRemoteFileStreamingMessageSource<F>> | |
| RemoteFileTemplate<F> |
A general abstraction for dealing with remote files.
|
| RemoteFileUtils |
Utility methods for supporting remote file operations.
|
| RendezvousChannel |
A zero-capacity version of
QueueChannel that delegates to a
SynchronousQueue internally. |
| RendezvousChannelSpec | |
| RenewableLockRegistry |
A
LockRegistry implementing this interface supports the renewal
of the time to live of a lock. |
| ReplyProducingMessageHandlerWrapper |
The
AbstractReplyProducingMessageHandler wrapper around raw MessageHandler
for request-reply scenarios, e.g. |
| ReplyRequiredException |
Exception that indicates no reply message is produced by a handler
that does have a value of true for the 'requiresReply' property.
|
| RequestHandlerCircuitBreakerAdvice |
A circuit breaker that stops calling a failing service after threshold
failures, until halfOpenAfter milliseconds has elapsed.
|
| RequestHandlerCircuitBreakerAdvice.CircuitBreakerOpenException |
An exception thrown when the circuit breaker is in an open state.
|
| RequestHandlerRetryAdvice |
Uses spring-retry to perform stateless or stateful retry.
|
| RequestMapping |
Class for mapping web requests onto specific
HttpRequestHandlingEndpointSupport. |
| RequestReplyExchanger |
Interface for a request/reply Message exchange.
|
| RequestReplyHeaderMapper<T> |
Request/Reply strategy interface for mapping
MessageHeaders to and from other
types of objects. |
| RequestResponseScenario |
Defines a Spring Integration request response test scenario.
|
| ResequencerParser |
Parser for the <resequencer> element.
|
| ResequencerSpec | |
| ResequencingMessageGroupProcessor |
This class implements all the strategy interfaces needed for a default resequencer.
|
| ResequencingMessageHandler |
Resequencer specific implementation of
AbstractCorrelatingMessageHandler. |
| ResettableFileListFilter<F> |
A
FileListFilter that can be reset by removing a specific file from its
state. |
| ResourceInboundChannelAdapterParser |
Parser for 'resource-inbound-channel-adapter'
|
| ResourceRetrievingMessageSource |
Implementation of
MessageSource based on
ResourcePatternResolver which will attempt to resolve Resources based
on the pattern specified. |
| ResultFactory |
Factory to create a
Result possibly taking into account the
provided message payload instance. |
| ResultToDocumentTransformer | |
| ResultToStringTransformer | |
| ResultTransformer |
Implementations of this class allow for the transformation of
Result
objects to other formats. |
| RetrievingJpaOutboundGatewayParser |
The Parser for the Retrieving Jpa Outbound Gateway.
|
| RetryAdviceParser | |
| RetryStateGenerator |
Strategy interface for generating a
RetryState instance
based on a message. |
| ReturnedAmqpMessageException |
A MessagingException for a returned message.
|
| ReversibleFileListFilter<F> |
A
FileListFilter that allows the caller to reverse (roll back) state
changes. |
| RFC5424MessageConverter |
MessageConverter; delegates to a RFC5424SyslogParser if
necessary (TCP will have already done the syslog conversion because it needs
to handle different message framing). |
| RFC5424SyslogParser |
Parse for RFC 5424 syslog messages; when used with TCP, requires the use
of a
RFC6587SyslogDeserializer which decodes the framing. |
| RFC5424SyslogParser.Reader | |
| RFC5424SyslogParser.Severity | |
| RFC6587SyslogDeserializer |
RFC5424/6587 Deserializer.
|
| RmiInboundGateway | Deprecated.
since 5.4 with no replacement.
|
| RmiInboundGatewayParser | Deprecated.
since 5.4 with no replacement.
|
| RmiNamespaceHandler | Deprecated.
since 5.4 with no replacement.
|
| RmiOutboundGateway | Deprecated.
since 5.4 with no replacement.
|
| RmiOutboundGateway.RmiProxyFactoryBeanConfigurer |
Allows configuration of the proxy factory bean before the RMI proxy is created.
|
| RmiOutboundGatewayParser | Deprecated.
since 5.4 with no replacement.
|
| Role |
Annotate endpoints to assign them to a role.
|
| RotatingServerAdvice |
A smart poller advice that rotates across multiple remote servers/directories.
|
| RotationPolicy |
A strategy for rotating advices to allow reconfiguring
the message source before and/or after a poll.
|
| RotationPolicy.KeyDirectory |
A key for a thread-local store and its related directory pair.
|
| RoundRobinLoadBalancingStrategy |
Round-robin implementation of
LoadBalancingStrategy. |
| Router |
Indicates that a method is capable of resolving to a channel or channel name
based on a message, message header(s), or both.
|
| RouterAnnotationPostProcessor |
Post-processor for Methods annotated with
@Router. |
| RouterFactoryBean |
Factory bean for creating a Message Router.
|
| RouterSpec<K,R extends AbstractMappingMessageRouter> |
The
AbstractRouterSpec for an AbstractMappingMessageRouter. |
| RoutingMessageHandlerNode |
Represents an endpoint that can route to multiple channels.
|
| RoutingSlipHeaderValueMessageProcessor |
The
RoutingSlip HeaderValueMessageProcessor specific implementation. |
| RoutingSlipRouteStrategy |
The
RoutingSlip strategy to determine the next replyChannel. |
| RSocketConnectedEvent |
An
IntegrationEvent to indicate that RSocket from the client is connected
to the server. |
| RSocketInboundGateway |
The
MessagingGatewaySupport implementation for the IntegrationRSocketEndpoint. |
| RSocketInboundGatewayParser |
Parser for the <inbound-gateway/> element of the 'rsocket' namespace.
|
| RSocketInboundGatewaySpec |
The
MessagingGatewaySpec implementation for the RSocketInboundGateway. |
| RSocketInteractionModel |
The RSocket protocol interaction models.
|
| RSocketNamespaceHandler |
Namespace handler for Spring Integration XML configuration for RSocket support.
|
| RSocketOutboundGateway |
An Outbound Messaging Gateway for RSocket requests.
|
| RSocketOutboundGatewayParser |
Parser for the 'outbound-gateway' element of the rsocket namespace.
|
| RSocketOutboundGatewaySpec |
The
MessageHandlerSpec implementation for the RSocketOutboundGateway. |
| RSockets |
The RSocket components Factory.
|
| RubyScriptExecutor |
A
DefaultScriptExecutor extension for Ruby scripting support. |
| SampleFacade | |
| ScatterGatherHandler |
The
MessageHandler implementation for the
Scatter-Gather EIP pattern. |
| ScatterGatherParser |
Parser for the <scatter-gather> element.
|
| ScatterGatherSpec |
A
GenericEndpointSpec extension for the ScatterGatherHandler. |
| ScriptExecutingMessageProcessor |
An
AbstractScriptExecutingMessageProcessor implementation for evaluating scripts
from the provided ScriptSource in the provided ScriptExecutor against an optional
binding variables. |
| ScriptExecutingMessageSource |
The
MessageSource strategy implementation
to produce a Message from underlying
ScriptExecutingMessageSource.scriptMessageProcessor for polling endpoints. |
| ScriptExecutingProcessorFactory |
The factory to create
AbstractScriptExecutingMessageProcessor instances for provided arguments. |
| ScriptExecutor |
A script evaluation abstraction against
ScriptSource and optional binding variables. |
| ScriptExecutorFactory |
The scripting configuration utilities.
|
| ScriptingException | |
| ScriptMessageSourceSpec |
The
MessageSourceSpec for Dynamic Language Scripts. |
| ScriptNamespaceHandler | |
| ScriptParser |
An
AbstractScriptParser parser extension for the <int-script:script> tag. |
| Scripts |
The factory for Dynamic Language Scripts (Groovy, Ruby, Python, JavaScript etc.).
|
| ScriptSpec |
The
MessageProcessorSpec implementation for the DslScriptExecutingMessageProcessor. |
| ScriptVariableGenerator |
Strategy interface to provide a
Map of variables to the script execution context. |
| SearchTermStrategy |
Strategy to be used to generate a
SearchTerm
See ImapMailReceiver |
| SecuredChannel |
An annotation to be applied for the
MessageChannel bean definition
from JavaConfig - on @Bean method level. |
| SecuredChannelsParser |
Creates a
ChannelSecurityInterceptor
to control send and receive access, and creates a bean post-processor to apply the
interceptor to MessageChannels
whose names match the specified patterns. |
| SecurityContextPropagationChannelInterceptor |
The
ExecutorChannelInterceptor
implementation responsible for
the SecurityContext propagation from one message flow's thread to another
through the MessageChannels involved in the flow. |
| SecurityIntegrationConfigurationInitializer |
The Integration Security infrastructure
beanFactory initializer. |
| SelectorChainParser |
Parser for the <selector-chain/> element.
|
| SelectorParser |
Parser for a top-level <selector/> element.
|
| SendTimers |
Success and failure timer stats.
|
| SendTimersAware | |
| SequenceSizeReleaseStrategy |
An implementation of
ReleaseStrategy that simply compares the current size of
the message list to the expected 'sequenceSize'. |
| SerializingHttpMessageConverter |
An
HttpMessageConverter implementation for
Serializable instances. |
| ServerRSocketConnector |
A server
AbstractRSocketConnector extension to accept and manage client RSocket connections. |
| ServerRSocketMessageHandler |
An
IntegrationRSocketMessageHandler extension for RSocket service side. |
| ServerWebSocketContainer | |
| ServerWebSocketContainer.SockJsServiceOptions | |
| ServerWebSocketContainerParser |
The
AbstractSingleBeanDefinitionParser implementation for
the <websocket:server-container/> element. |
| ServiceActivatingHandler | |
| ServiceActivator |
Indicates that a method is capable of handling a message or message payload.
|
| ServiceActivatorAnnotationPostProcessor |
Post-processor for Methods annotated with
@ServiceActivator. |
| ServiceActivatorFactoryBean |
FactoryBean for creating
ServiceActivatingHandler instances. |
| ServiceActivatorParser |
Parser for the <service-activator> element.
|
| ServiceUnavailableException |
The
WebServiceException extension to indicate that the server endpoint is
temporary unavailable. |
| Session<F> |
Common abstraction for a Session with a remote File system.
|
| SessionCallback<F,T> |
Callback invoked by
RemoteFileOperations.execute() - allows multiple operations
on a session. |
| SessionCallbackWithoutResult<F> |
Simple convenience implementation of
SessionCallback for cases where
no result is returned. |
| SessionClosedEvent |
An event emitted when a session is closed.
|
| SessionClosedEvent |
An event emitted when a session is closed.
|
| SessionFactory<F> |
Factory for acquiring
Session instances. |
| SessionFactoryLocator<F> |
A factory returning a
SessionFactory based on some key. |
| SessionFactoryMapBuilder<T> |
A
MapBuilder to producer a map that maps objects to SessionFactorys. |
| SessionOpenedEvent |
An event emitted when a session is opened.
|
| SessionOpenedEvent |
An event emitted when a session is opened.
|
| Sftp |
The factory for SFTP components.
|
| SftpFileInfo |
A
FileInfo implementation for SFTP. |
| SftpInboundChannelAdapterParser |
Parser for 'sftp:inbound-channel-adapter'
|
| SftpInboundChannelAdapterSpec | |
| SftpInboundFileSynchronizer |
Handles the synchronization between a remote SFTP directory and a local mount.
|
| SftpInboundFileSynchronizingMessageSource |
A
MessageSource implementation for SFTP
that delegates to an InboundFileSynchronizer. |
| SftpMessageHandler |
Subclass of
FileTransferringMessageHandler for SFTP. |
| SftpMessageHandlerSpec | |
| SftpNamespaceHandler |
Provides namespace support for using SFTP.
|
| SftpOutboundChannelAdapterParser |
Parser for SFTP Outbound Channel Adapters.
|
| SftpOutboundGateway |
Outbound Gateway for performing remote file operations via SFTP.
|
| SftpOutboundGatewayParser | |
| SftpOutboundGatewaySpec | |
| SftpPersistentAcceptOnceFileListFilter |
Persistent file list filter using the server's file timestamp to detect if we've already
'seen' this file.
|
| SftpRegexPatternFileListFilter |
Implementation of
AbstractRegexPatternFileListFilter for SFTP. |
| SftpRemoteFileTemplate |
SFTP version of
RemoteFileTemplate providing type-safe access to
the underlying ChannelSftp object. |
| SftpSession |
Default SFTP
Session implementation. |
| SftpSimplePatternFileListFilter |
Implementation of
AbstractSimplePatternFileListFilter for SFTP. |
| SftpStreamingInboundChannelAdapterParser | |
| SftpStreamingInboundChannelAdapterSpec | |
| SftpStreamingMessageSource |
Message source for streaming SFTP remote file contents.
|
| SftpSystemMarkerFilePresentFileListFilter |
SFTP implementation of
AbstractMarkerFilePresentFileListFilter. |
| SharedSessionCapable |
A
SessionFactory that implements this interface is capable of supporting a shared session. |
| SimpleAcknowledgment |
Opaque object for manually acknowledging.
|
| SimpleActiveIdleMessageSourceAdvice | Deprecated.
since 5.3 in favor of
SimpleActiveIdleReceiveMessageAdvice with the same
(but more common) functionality. |
| SimpleActiveIdleReceiveMessageAdvice |
A simple advice that polls at one rate when messages exist and another when
there are no messages.
|
| SimpleFromAvroTransformer |
An Apache Avro transformer to create generated
SpecificRecord objects
from byte[]. |
| SimpleJsonSerializer |
Extremely simple JSON serializer.
|
| SimpleMessageConverter | |
| SimpleMessageGroup |
Represents a mutable group of correlated messages that is bound to a certain
MessageStore and group id. |
| SimpleMessageGroupFactory |
The
MessageGroupFactory implementation to produce SimpleMessageGroup instances. |
| SimpleMessageGroupFactory.GroupType | |
| SimpleMessageGroupProcessor |
A
MessageGroupProcessor that simply returns the messages in the group. |
| SimpleMessageListenerContainerSpec |
Spec for a
SimpleMessageListenerContainer. |
| SimpleMessageStore |
Map-based in-memory implementation of
MessageStore and MessageGroupStore. |
| SimpleMetadataStore |
Simple implementation of
MetadataStore that uses a ConcurrentMap for the data store. |
| SimpleMultipartFileReader |
MultipartFileReader implementation that does not maintain metadata from
the original MultipartFile instance. |
| SimplePatternFileListFilter |
Filter that supports ant style path expressions, which are less powerful but more readable than regular expressions.
|
| SimplePollSkipStrategy |
A simple
PollSkipStrategy to be used with a PollSkipAdvice. |
| SimplePool<T> |
Implementation of
Pool supporting dynamic resizing and a variable
timeout when attempting to obtain an item from the pool. |
| SimplePool.PoolItemCallback<T> |
User of the pool provide an implementation of this interface; called during
various pool operations.
|
| SimplePublisherMetadataSource |
Simple implementation of
PublisherMetadataSource that allows for
configuration of a single channel name, payload expression, and
array of header key=value expressions. |
| SimpleSequenceSizeReleaseStrategy |
An implementation of
ReleaseStrategy that simply compares the current size of
the message list to the expected 'sequenceSize'. |
| SimpleToAvroTransformer |
An Apache Avro transformer for generated
SpecificRecord objects. |
| SimpleWebServiceInboundGateway | |
| SimpleWebServiceOutboundGateway |
An outbound Messaging Gateway for invoking a Web Service.
|
| SimpleWsInboundGatewaySpec |
The spec for a
SimpleWebServiceInboundGateway. |
| SimpleWsOutboundGatewaySpec |
The spec for a
SimpleWebServiceOutboundGateway. |
| SimpleWsOutboundGatewaySpec.SimpleWsOutboundGatewayNoTemplateSpec |
Spec for a
SimpleWebServiceOutboundGateway where an external
WebServiceTemplate is not provided. |
| SingleRequestResponseScenarioTests |
Convenience class for a single
RequestResponseScenario test |
| SmartLifecycleRoleController |
Bulk start/stop
SmartLifecycle in a particular role in phase order. |
| SoapHeaderMapper |
A convenience interface that extends
RequestReplyHeaderMapper,
parameterized with SoapHeader. |
| SocketCustomizer |
Configures a socket.
|
| SocketInfo |
Simple wrapper around
Socket providing access to getters (except
input/output streams). |
| SoftEndOfStreamException |
Used to communicate that a stream has closed, but between logical
messages.
|
| SourceCreatingTransformer |
Transforms the payload to a
Source using a SourceFactory. |
| SourceFactory |
Factory to create a
Source possibly taking into account
the provided message payload instance. |
| SourcePollingChannelAdapter |
A Channel Adapter implementation for connecting a
MessageSource to a MessageChannel. |
| SourcePollingChannelAdapterFactoryBean |
FactoryBean for creating a SourcePollingChannelAdapter instance.
|
| SourcePollingChannelAdapterSpec | |
| SpelExpressionRetryStateGenerator |
Creates a DefaultRetryState from a
Message. |
| SpelFunctionFactoryBean |
A
FactoryBean implementation to encapsulate the population of a static Method
from the provided SpelFunctionFactoryBean.functionClass and SpelFunctionFactoryBean.functionMethodSignature as
a valid StandardEvaluationContext function. |
| SpelFunctionParser |
Parser for the <spel-function> element.
|
| SpelPropertyAccessorRegistrar |
Utility class that keeps track of a Set of SpEL
PropertyAccessors
in order to register them with the "integrationEvaluationContext" upon initialization. |
| SpelPropertyAccessorsParser |
Parser for the <spel-property-accessors> element.
|
| Splitter |
Indicates that a method is capable of splitting a single message or message
payload to produce multiple messages or payloads.
|
| SplitterAnnotationPostProcessor |
Post-processor for Methods annotated with
@Splitter. |
| SplitterEndpointSpec<S extends AbstractMessageSplitter> |
A
ConsumerEndpointSpec for a AbstractMessageSplitter implementations. |
| SplitterFactoryBean |
Factory bean for creating a Message Splitter.
|
| SplitterParser |
Parser for the <splitter/> element.
|
| SpringIntegrationTest |
Annotation that can be specified on a test class that runs Spring Integration based tests.
|
| SqlParameterSourceFactory |
Collaborator for JDBC adapters which allows creation of
instances of
SqlParameterSource for use in update operations. |
| SqlServerChannelMessageStoreQueryProvider |
Channel message store query provider for Microsoft SQL Server / Azure SQL database.
|
| StackTraceUtils |
Utility methods for analyzing stack traces.
|
| StandardHeaderEnricherParser |
Parser for the <header-enricher> element within the core integration
namespace.
|
| StandardIntegrationFlow |
The standard implementation of the
IntegrationFlow interface instantiated
by the Framework. |
| StandardIntegrationFlowContext |
Standard implementation of
IntegrationFlowContext. |
| StandardRotationPolicy |
Standard rotation policy; iterates over key/directory pairs; when the end is reached,
starts again at the beginning.
|
| StaticHeaderValueMessageProcessor<T> | |
| StaticMessageHeaderAccessor |
Lightweight type-safe header accessor avoiding object
creation just to access a header.
|
| StompConnectionFailedEvent |
The
StompIntegrationEvent implementation for the failed connection exceptions. |
| StompExceptionEvent |
The
StompIntegrationEvent implementation for the exception from STOMP Adapters. |
| StompHeaderMapper |
The STOMP
HeaderMapper implementation. |
| StompInboundChannelAdapter |
The
MessageProducerSupport for STOMP protocol to handle STOMP frames from
provided destination and send messages to the outputChannel. |
| StompInboundChannelAdapterParser |
The
AbstractChannelAdapterParser implementation for
the <stomp:inbound-channel-adapter/> element. |
| StompIntegrationEvent |
Base class for all
IntegrationEvents generated by the STOMP Adapters. |
| StompMessageHandler |
The
AbstractMessageHandler implementation to send messages to STOMP destinations. |
| StompNamespaceHandler | |
| StompOutboundChannelAdapterParser |
The
AbstractOutboundChannelAdapterParser implementation for
the <stomp:outbound-channel-adapter/> element. |
| StompReceiptEvent |
The
StompIntegrationEvent for the STOMP RECEIPT Frames or lost receipts. |
| StompSessionConnectedEvent |
The
StompIntegrationEvent indicating the STOMP session establishment. |
| StompSessionManager |
An abstraction to manage the STOMP Session and connection/disconnection
for
StompSessionHandler. |
| StoredProcExecutor |
This class is used by all Stored Procedure (Stored Function) components and
provides the core functionality to execute those.
|
| StoredProcMessageHandler |
A message handler that executes Stored Procedures for update purposes.
|
| StoredProcMessageHandlerParser | |
| StoredProcOutboundGateway |
An
AbstractReplyProducingMessageHandler implementation for performing
RDBMS stored procedures which return results. |
| StoredProcOutboundGatewayParser | |
| StoredProcParserUtils | |
| StoredProcPollingChannelAdapter |
A polling channel adapter that creates messages from the payload returned by
executing a stored procedure or Sql function.
|
| StoredProcPollingChannelAdapterParser | |
| StreamClosedEvent |
Application event published when EOF is detected on a stream.
|
| StreamNamespaceHandler | |
| StreamTransformer |
Transforms an InputStream payload to a byte[] or String (if a
charset is provided).
|
| StreamTransformerParser |
Parser for
<stream-transformer/> element. |
| StringObjectMapBuilder |
A map builder creating a map with String keys and values.
|
| StringResultFactory | |
| StringSourceFactory |
SourceFactory implementation which supports creation of a StringSource
from a Document, File or String payload |
| StringStringMapBuilder |
A map builder creating a map with String keys and values.
|
| StringValueTestXPathMessageSelector | |
| SubProtocolHandlerRegistry |
The utility class to encapsulate search algorithms for a set of provided
SubProtocolHandlers. |
| SubscribableChannelManagement |
Metrics for subscribable channels.
|
| SubscribableJmsChannel |
An
AbstractJmsChannel implementation for message-driven subscriptions. |
| SubscribableKafkaChannel |
Subscribable channel backed by a Kafka topic.
|
| SubscribableRedisChannel |
An
AbstractMessageChannel implementation with BroadcastCapableChannel
aspect to provide a pub-sub semantics to consume messages fgrom Redis topic. |
| SupplierExpression<T> | |
| SyslogHeaders |
Headers in a
Map generated by the @link SyslogToMapTransformer that
will be added to Spring Integration messages as headers, prefixed by SyslogHeaders.PREFIX. |
| SyslogInboundChannelAdapterParser |
Parses a
<int-syslog:inbound-channel-adapter/>. |
| SyslogNamespaceHandler |
Namspace handler for spring-integration-syslog.
|
| SyslogReceivingChannelAdapterFactoryBean |
Factory bean to create syslog inbound adapters (UDP or TCP).
|
| SyslogReceivingChannelAdapterFactoryBean.Protocol | |
| SyslogReceivingChannelAdapterSupport |
Base support class for inbound channel adapters.
|
| SyslogToMapTransformer |
Transforms a packet in Syslog (RFC3164) format to a Map.
|
| SyslogToMapTransformerParser | |
| TailAdapterSpec |
A
MessageProducerSpec for file tailing adapters. |
| Tcp |
Factory methods for TCP.
|
| TcpClientConnectionFactorySpec | |
| TcpCodecs |
Factory class to create TCP Serializer/Deserializers used to
encode/decode messages to/from a TCP stream.
|
| TcpConnection |
An abstraction over
Socket and SocketChannel
that sends Message objects by serializing the payload and streaming it to the
destination. |
| TcpConnectionCloseEvent | |
| TcpConnectionEvent |
ApplicationEvent representing normal operations on a
TcpConnection. |
| TcpConnectionExceptionEvent |
ApplicationEvent representing exceptions on a
TcpConnection. |
| TcpConnectionFactoryFactoryBean |
Instantiates a TcpN(et|io)(Server|Client)ConnectionFactory, depending
on type and using-nio attributes.
|
| TcpConnectionFactoryParser | |
| TcpConnectionFailedCorrelationEvent |
An event emitted when an endpoint cannot correlate a connection id to a
connection; the cause is a messaging exception with the failed message.
|
| TcpConnectionFailedEvent |
An event emitted when a connection could not be established for some
reason.
|
| TcpConnectionInterceptor | |
| TcpConnectionInterceptorFactory |
Interface for TCP connection interceptor factories.
|
| TcpConnectionInterceptorFactoryChain | |
| TcpConnectionInterceptorSupport |
Base class for
TcpConnectionInterceptors; passes all method calls through
to the underlying TcpConnection. |
| TcpConnectionOpenEvent | |
| TcpConnectionServerExceptionEvent |
IpIntegrationEvent representing exceptions on a TCP server socket/channel. |
| TcpConnectionServerListeningEvent |
IpIntegrationEvent emitted when a server begins listening. |
| TcpConnectionSupport |
Base class for TcpConnections.
|
| TcpDeserializationExceptionEvent |
Event representing an exception while decoding an incoming stream.
|
| TcpInboundChannelAdapterParser |
Channel Adapter that receives TCP stream frames and maps them to Messages.
|
| TcpInboundChannelAdapterSpec | |
| TcpInboundGateway |
Inbound Gateway using a server connection factory - threading is controlled by the
factory.
|
| TcpInboundGatewayParser | |
| TcpInboundGatewaySpec | |
| TcpListener |
Classes that implement this interface may register with a
connection factory to receive messages retrieved from a
TcpConnection |
| TcpMessageMapper |
Maps incoming data from a
TcpConnection to a Message. |
| TcpNetClientConnectionFactory |
A client connection factory that creates
TcpNetConnections. |
| TcpNetConnection |
A TcpConnection that uses and underlying
Socket. |
| TcpNetConnectionSupport |
Used by NET connection factories to instantiate a
TcpNetConnection object. |
| TcpNetServerConnectionFactory |
Implements a server connection factory that produces
TcpNetConnections using
a ServerSocket. |
| TcpNioClientConnectionFactory |
A client connection factory that creates
TcpNioConnections. |
| TcpNioConnection |
A TcpConnection that uses and underlying
SocketChannel. |
| TcpNioConnectionSupport |
Used by NIO connection factories to instantiate a
TcpNioConnection object. |
| TcpNioServerConnectionFactory |
/**
Implements a server connection factory that produces
TcpNioConnections using
a ServerSocketChannel. |
| TcpNioSSLConnection |
Implementation of
TcpConnection supporting SSL/TLS over NIO. |
| TcpOutboundChannelAdapterParser | |
| TcpOutboundChannelAdapterSpec | |
| TcpOutboundGateway |
TCP outbound gateway that uses a client connection factory.
|
| TcpOutboundGatewayParser |
Parser for the <outbound-gateway> element of the integration 'jms' namespace.
|
| TcpOutboundGatewaySpec |
A
MessageHandlerSpec for TcpOutboundGateways. |
| TcpReceivingChannelAdapter |
Tcp inbound channel adapter using a TcpConnection to
receive data - if the connection factory is a server
factory, this Listener owns the connections.
|
| TcpSender |
An interface representing a sending client of a connection
factory.
|
| TcpSendingMessageHandler |
Tcp outbound channel adapter using a TcpConnection to
send data - if the connection factory is a server
factory, the TcpListener owns the connections.
|
| TcpServerConnectionFactory |
Connection factories that act as TCP servers, listening for incoming connections.
|
| TcpServerConnectionFactorySpec | |
| TcpSocketFactorySupport |
Strategy interface for supplying Socket Factories.
|
| TcpSocketSupport |
Strategy interface for modifying sockets.
|
| TcpSSLContextSupport |
Strategy interface for the creation of an
SSLContext object
for use with SSL/TLS sockets. |
| TcpSyslogReceivingChannelAdapter |
TCP implementation of a syslog inbound channel adapter.
|
| TestingUtilities |
Convenience class providing methods for testing IP components.
|
| TestMailServer |
A basic test mail server for pop3, imap,
Serves up a canned email message with each protocol.
|
| TestMailServer.ImapServer | |
| TestMailServer.MailServer | |
| TestMailServer.Pop3Server | |
| TestMailServer.SmtpServer | |
| TestUtils | |
| TestUtils.LevelsContainer | |
| TestUtils.TestApplicationContext |
A
GenericApplicationContext extension with some support methods
to register Spring Integration beans in the application context at runtime. |
| ThreadAffinityClientConnectionFactory |
A client connection factory that binds a connection to a thread.
|
| ThreadStatePropagationChannelInterceptor<S> |
The
ExecutorChannelInterceptor implementation responsible for
the Thread (any?) state propagation from one message flow's thread to another
through the MessageChannels involved in the flow. |
| TimeoutCountSequenceSizeReleaseStrategy |
A
ReleaseStrategy that releases all messages if any of the following is true:
The sequence is complete (if there is one).
There are more messages than a threshold set by the user.
The time elapsed since the earliest message, according to their timestamps, if
present, exceeds a timeout set by the user.
|
| TimerFacade | |
| TimerStats |
Statistics captured from a timer meter.
|
| TrackableComponent | |
| TransactionHandleMessageAdvice |
A
TransactionInterceptor extension with HandleMessageAdvice marker. |
| TransactionInterceptorBuilder |
Provides a fluent API to build a transaction interceptor.
|
| TransactionSynchronizationFactory |
Strategy for implementing factories that create
TransactionSynchronization |
| TransactionSynchronizationFactoryBean |
The
FactoryBean implementation (with Builder style) to be used
from JavaConfig to populate DefaultTransactionSynchronizationFactory bean. |
| TransactionSynchronizationFactoryParser |
Parser for transaction-synchronizatioin-factory element
|
| TransactionSynchronizationProcessor |
Strategy for implementing transaction synchronization processors
|
| Transformer |
Indicates that a method is capable of transforming a message, message header,
or message payload.
|
| Transformer |
Strategy interface for transforming a
Message. |
| TransformerAnnotationPostProcessor |
Post-processor for Methods annotated with a
@Transformer. |
| TransformerFactoryBean |
Factory bean for creating a Message Transformer.
|
| TransformerParser |
Parser for the <transformer/> element.
|
| Transformers |
An utility class to provide methods for out-of-the-box
Transformers. |
| Udp |
Factory methods for UDP.
|
| UdpInboundChannelAdapterParser |
Channel Adapter that receives UDP datagram packets and maps them to Messages.
|
| UdpInboundChannelAdapterSpec | |
| UdpMulticastOutboundChannelAdapterSpec | |
| UdpOutboundChannelAdapterParser | |
| UdpServerListeningEvent |
IpIntegrationEvent emitted when a server begins listening. |
| UdpSyslogReceivingChannelAdapter |
UDP implementation of a syslog inbound channel adapter.
|
| UdpUnicastOutboundChannelAdapterSpec | |
| UnexpiredMessageSelector |
A
MessageSelector that accepts Messages that are
not yet expired. |
| UnicastingDispatcher |
Implementation of
MessageDispatcher that will attempt to send a
Message to at most one of its handlers. |
| UnicastReceivingChannelAdapter |
A channel adapter to receive incoming UDP packets.
|
| UnicastSendingMessageHandler |
A
MessageHandler implementation that maps a Message into
a UDP datagram packet and sends that to the specified host and port. |
| UniqueExpiryCallback |
A marker interface extension of the
MessageGroupStore.MessageGroupCallback
for components which should be registered in the MessageGroupStore only once. |
| UniqueMethodFilter | |
| UnmarshallingTransformer |
An implementation of
Transformer
that delegates to an OXM Unmarshaller. |
| UnmarshallingTransformerParser | |
| UpdatingJpaOutboundGatewayParser |
The Parser for Updating JPA Outbound Gateway.
|
| UploadedMultipartFile |
A
MultipartFile implementation that represents an uploaded File. |
| UpperBound |
Thin wrapper around a Semaphore that allows to create a potentially unlimited upper bound
to by used in buffers of messages (e.g.
|
| UseSpelInvoker |
Indicates that a POJO handler method (
@ServiceActivator, @Transformer, etc.,
or such methods invoked from XML definitions) should be invoked using SpEL. |
| UUIDConverter |
Utility to help generate UUID instances from generic objects.
|
| ValueExpression<V> |
A very simple hardcoded implementation of the
Expression interface that represents an
immutable value. |
| VetoCapableInterceptor |
ChannelInterceptors implementing this
interface can veto global interception of a particular channel. |
| WebFlux |
The WebFlux components Factory.
|
| WebFluxContextUtils |
Utility class for accessing WebFlux integration components
from the
BeanFactory. |
| WebFluxInboundEndpoint |
A
MessagingGatewaySupport
implementation for Spring WebFlux HTTP requests execution. |
| WebFluxInboundEndpointParser | |
| WebFluxInboundEndpointSpec |
The
HttpInboundEndpointSupportSpec implementation for the WebFluxInboundEndpoint. |
| WebFluxIntegrationConfigurationInitializer |
The WebFlux Integration infrastructure
beanFactory initializer. |
| WebFluxIntegrationRequestMappingHandlerMapping |
The
HandlerMapping implementation that
detects and registers RequestMappingInfos for
HttpRequestHandlingEndpointSupport
from a Spring Integration HTTP configuration
of <inbound-channel-adapter/> and <inbound-gateway/> elements. |
| WebFluxMessageHandlerSpec |
The
BaseHttpMessageHandlerSpec implementation for the WebFluxRequestExecutingMessageHandler. |
| WebFluxNamespaceHandler |
Namespace handler for Spring Integration's webflux namespace.
|
| WebFluxOutboundChannelAdapterParser |
Parser for the 'outbound-channel-adapter' element of the webflux namespace.
|
| WebFluxOutboundGatewayParser |
Parser for the 'outbound-gateway' element of the webflux namespace.
|
| WebFluxRequestExecutingMessageHandler |
A
MessageHandler implementation that executes
HTTP requests by delegating to a Reactive WebClient instance. |
| WebServiceHeaderEnricherParser | |
| WebServiceHeaders |
Pre-defined header names to be used when storing or retrieving
Web Service properties to/from integration Message Headers.
|
| WebServiceInboundGatewayParser | |
| WebServiceOutboundGatewayParser |
Parser for the <outbound-gateway/> element in the 'ws' namespace.
|
| WebSocketInboundChannelAdapter | |
| WebSocketInboundChannelAdapterParser |
The
AbstractChannelAdapterParser implementation for
the <int-websocket:inbound-channel-adapter/> element. |
| WebSocketIntegrationConfigurationInitializer |
The WebSocket Integration infrastructure
beanFactory initializer. |
| WebSocketListener |
A contract for handling incoming
WebSocketMessages messages as part of a higher
level protocol, referred to as "sub-protocol" in the WebSocket RFC specification. |
| WebSocketNamespaceHandler | |
| WebSocketOutboundMessageHandler | |
| WebSocketOutboundMessageHandlerParser |
The
AbstractOutboundChannelAdapterParser implementation for
the <websocket:outbound-channel-adapter/> element. |
| WebSocketStompSessionManager |
The
WebSocketStompClient based AbstractStompSessionManager implementation. |
| WhileLockedProcessor |
A simple strategy callback class that allows you to provide
a code that needs to be executed under
Lock provided by
LockRegistry
A typical usage would be to provide implementation of WhileLockedProcessor.whileLocked() method and
then call WhileLockedProcessor.doWhileLocked() |
| WireTap |
A
ChannelInterceptor that publishes a copy of the intercepted message
to a secondary target while still sending the original message to the main channel. |
| WireTapParser |
Parser for the <wire-tap> element.
|
| WireTapSpec |
The
IntegrationComponentSpec implementation for the WireTap component. |
| Ws |
Factory class for web service components.
|
| WsIntegrationConfigurationInitializer |
The
IntegrationConfigurationInitializer implementation for the WebService module. |
| WsNamespaceHandler | |
| XmlPayloadConverter | |
| XmlPayloadValidatingFilterParser | |
| XmlValidatingMessageSelector | |
| XmlValidatingMessageSelector.SchemaType | |
| XmppConnectionFactoryBean |
This class configures an
XMPPTCPConnection object. |
| XmppConnectionParser |
Parser for 'xmpp:xmpp-connection' element
|
| XmppContextUtils | |
| XmppHeaderEnricherParser |
Parser for 'xmpp:header-enricher' element
|
| XmppHeaderMapper |
A convenience interface that extends
RequestReplyHeaderMapper
but parameterized with the Smack API Message. |
| XmppHeaders |
Used as keys for
Message objects
that handle XMPP events. |
| XmppNamespaceHandler |
This class parses the schema for XMPP support.
|
| XPathEvaluationType |
Enumeration of different types of XPath evaluation used to indicate the type
of evaluation that should be carried out using a provided XPath expression.
|
| XPathExpressionEvaluatingHeaderValueMessageProcessor | |
| XPathExpressionParser |
Parser for the <xpath-expression> element.
|
| XPathFilterParser |
Parser for the <xpath-filter> element.
|
| XPathHeaderEnricher |
Transformer implementation that evaluates XPath expressions against the
message payload and inserts the result of the evaluation into a message
header.
|
| XPathHeaderEnricherParser |
Parser for <xpath-header-enricher> elements.
|
| XPathMessageSplitter |
Message Splitter that uses an
XPathExpression to split a
Document, File or String payload into a NodeList. |
| XPathMessageSplitterParser | |
| XPathRouter |
Message Router that uses
XPathExpression evaluation to determine channel names. |
| XPathRouterParser |
Parser for the <xpath-router/> element.
|
| XPathTransformer |
Transformer implementation that evaluates an XPath expression against the inbound
Message payload and returns a Message whose payload is the result of that evaluation.
|
| XPathTransformerParser |
Parser for the 'xpath-transformer' element.
|
| XPathUtils |
Utility class for 'xpath' support.
|
| XsltPayloadTransformer | |
| XsltPayloadTransformerParser | |
| ZeroMq |
Factory class for ZeroMq components DSL.
|
| ZeroMqChannel |
The
SubscribableChannel implementation over ZeroMQ sockets. |
| ZeroMqChannelSpec |
The
MessageChannelSpec for a ZeroMqChannel. |
| ZeroMqHeaders |
The message headers constants to repsent ZeroMq message attributes.
|
| ZeroMqMessageHandler |
The
AbstractReactiveMessageHandler implementation for publishing messages over ZeroMq socket. |
| ZeroMqMessageHandlerSpec |
The
ReactiveMessageHandlerSpec extension for ZeroMqMessageHandler. |
| ZeroMqMessageProducer |
A
MessageProducerSupport implementation for consuming messages from ZeroMq socket. |
| ZeroMqMessageProducerSpec | |
| ZeroMqProxy |
This class encapsulates the logic to configure and manage a ZeroMQ proxy.
|
| ZeroMqProxy.Type | |
| ZookeeperLockRegistry |
ExpirableLockRegistry implementation using Zookeeper, or more specifically,
Curator InterProcessMutex. |
| ZookeeperLockRegistry.KeyToPathStrategy |
Strategy to convert a lock key (e.g.
|
| ZookeeperMetadataStore |
Zookeeper-based
ListenableMetadataStore based on a Zookeeper node. |
| ZookeeperMetadataStoreException | |
| ZookeeperNamespaceHandler |