Package | Description |
---|---|
org.springframework.integration.aggregator |
Provides classes related to message aggregation.
|
org.springframework.integration.amqp.outbound |
Provides classes supporting outbound endpoints.
|
org.springframework.integration.channel |
Provides classes representing various channel types.
|
org.springframework.integration.config |
Base package for configuration.
|
org.springframework.integration.config.annotation |
Provides classes supporting annotation-based configuration.
|
org.springframework.integration.core |
Provides core classes.
|
org.springframework.integration.dispatcher |
Provides classes related to dispatching messages.
|
org.springframework.integration.endpoint |
Provides core classes related to Endpoints.
|
org.springframework.integration.event.outbound |
Provides classes supporting outbound endpoints.
|
org.springframework.integration.file |
Base package for File support.
|
org.springframework.integration.file.remote.gateway |
Provides classes supporting remote file gateways.
|
org.springframework.integration.file.remote.handler |
Provides classes supporting remote file message handlers.
|
org.springframework.integration.filter |
Provides classes supporting the filter pattern.
|
org.springframework.integration.ftp.gateway |
Provides classes supporting FTP gateways.
|
org.springframework.integration.groovy.config |
Provides classes for configuration - parsers, namespace handlers, factory beans.
|
org.springframework.integration.handler |
Provides classes implementing various types of message handler.
|
org.springframework.integration.http.outbound |
Provides classes supporting outbound endpoints.
|
org.springframework.integration.ip |
Base package for IP (TCP/UDP) Support.
|
org.springframework.integration.ip.tcp |
Base package for TCP Support.
|
org.springframework.integration.ip.udp |
Base package for UDP support.
|
org.springframework.integration.jdbc |
Root package of the Spring Integration JDBC module, which contains various
JDBC and Stored Procedure/Function supporting components.
|
org.springframework.integration.jms |
Base package for JMS Support.
|
org.springframework.integration.jmx |
Base package for JMX support.
|
org.springframework.integration.jpa.outbound |
Provides Spring Integration components for doing outbound operations.
|
org.springframework.integration.mail |
Base package for Mail support.
|
org.springframework.integration.mongodb.outbound |
Provides classes related to the Mongo outbound channel adapters
|
org.springframework.integration.monitor |
Provides classes related to Spring Integration managed resources.
|
org.springframework.integration.redis.channel |
Provides classes related to Redis-backed channels.
|
org.springframework.integration.redis.outbound |
Provides classes supporting outbound endpoints.
|
org.springframework.integration.rmi |
Base package for RMI support.
|
org.springframework.integration.router |
Provides classes supporting the router pattern.
|
org.springframework.integration.sftp.gateway |
Provides classes supporting SFTP gateways.
|
org.springframework.integration.splitter |
Provides classes supporting the splitter pattern.
|
org.springframework.integration.stream |
Base package for stream support.
|
org.springframework.integration.test.support |
Provides several test support classes including for testing Spring Integration
request-response message scenarios.
|
org.springframework.integration.test.util |
Provides various test utilities, for example
TestUtils provides convenience
helpers to easily retrieve private bean properties. |
org.springframework.integration.transformer |
Contains core-implementation of various Transformers which includes Enrichers
and Filters.
|
org.springframework.integration.twitter.outbound |
Provides outbound Twitter components.
|
org.springframework.integration.ws |
Provides several inbound and outbound Web Service components.
|
org.springframework.integration.xml.router |
Provides XML message routers.
|
org.springframework.integration.xml.splitter |
Provides implementations of
AbstractMessageSplitter . |
org.springframework.integration.xmpp.core |
Provides classes shared across all XMPP components.
|
org.springframework.integration.xmpp.outbound |
Provides XMPP outbound Messagehandler implementations.These components extend
AbstractXmppConnectionAwareMessageHandler |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCorrelatingMessageHandler
Abstract Message handler that holds a buffer of correlated messages in a
MessageStore . |
class |
AggregatingMessageHandler
Aggregator specific implementation of
AbstractCorrelatingMessageHandler . |
class |
CorrelatingMessageBarrier
This Endpoint serves as a barrier for messages that should not be processed yet.
|
class |
ResequencingMessageHandler
Resequencer specific implementation of
AbstractCorrelatingMessageHandler . |
Modifier and Type | Class and Description |
---|---|
class |
AmqpOutboundEndpoint
Adapter that converts and sends Messages to an AMQP Exchange.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractSubscribableChannel.subscribe(MessageHandler handler) |
boolean |
AbstractSubscribableChannel.unsubscribe(MessageHandler handle) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSimpleMessageHandlerFactoryBean<H extends MessageHandler> |
Modifier and Type | Method and Description |
---|---|
protected MessageHandler |
ExpressionControlBusFactoryBean.createHandler() |
Modifier and Type | Method and Description |
---|---|
Class<? extends MessageHandler> |
AbstractSimpleMessageHandlerFactoryBean.getObjectType() |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerEndpointFactoryBean.setHandler(MessageHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected MessageHandler |
AggregatorAnnotationPostProcessor.createHandler(Object bean,
Method method,
Aggregator annotation) |
protected MessageHandler |
FilterAnnotationPostProcessor.createHandler(Object bean,
Method method,
Filter annotation) |
protected MessageHandler |
RouterAnnotationPostProcessor.createHandler(Object bean,
Method method,
Router annotation) |
protected MessageHandler |
ServiceActivatorAnnotationPostProcessor.createHandler(Object bean,
Method method,
ServiceActivator annotation) |
protected MessageHandler |
SplitterAnnotationPostProcessor.createHandler(Object bean,
Method method,
Splitter annotation) |
protected abstract MessageHandler |
AbstractMethodAnnotationPostProcessor.createHandler(Object bean,
Method method,
T annotation)
Subclasses must implement this method to create the MessageHandler.
|
protected MessageHandler |
TransformerAnnotationPostProcessor.createHandler(Object bean,
Method method,
Transformer annotation) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMethodAnnotationPostProcessor.setAdviceChainIfPresent(String beanName,
T annotation,
MessageHandler handler) |
Modifier and Type | Method and Description |
---|---|
boolean |
SubscribableChannel.subscribe(MessageHandler handler)
Register a
MessageHandler as a subscriber to this channel. |
boolean |
SubscribableChannel.unsubscribe(MessageHandler handler)
Remove a
MessageHandler from the subscribers of this channel. |
Modifier and Type | Method and Description |
---|---|
Iterator<MessageHandler> |
RoundRobinLoadBalancingStrategy.getHandlerIterator(Message<?> message,
Collection<MessageHandler> handlers)
Returns an iterator that starts at a new point in the collection every time the
first part of the list that is skipped will be used at the end of the
iteration, so it guarantees all handlers are returned once on subsequent
next() invocations. |
Iterator<MessageHandler> |
LoadBalancingStrategy.getHandlerIterator(Message<?> message,
Collection<MessageHandler> handlers) |
protected Set<MessageHandler> |
AbstractDispatcher.getHandlers()
Returns an unmodifiable
Set of this dispatcher's handlers. |
Modifier and Type | Method and Description |
---|---|
boolean |
MessageDispatcher.addHandler(MessageHandler handler) |
boolean |
AbstractDispatcher.addHandler(MessageHandler handler)
Add the handler to the internal Set.
|
boolean |
MessageDispatcher.removeHandler(MessageHandler handler) |
boolean |
AbstractDispatcher.removeHandler(MessageHandler handler)
Remove the handler from the internal handler Set.
|
Modifier and Type | Method and Description |
---|---|
Iterator<MessageHandler> |
RoundRobinLoadBalancingStrategy.getHandlerIterator(Message<?> message,
Collection<MessageHandler> handlers)
Returns an iterator that starts at a new point in the collection every time the
first part of the list that is skipped will be used at the end of the
iteration, so it guarantees all handlers are returned once on subsequent
next() invocations. |
Iterator<MessageHandler> |
LoadBalancingStrategy.getHandlerIterator(Message<?> message,
Collection<MessageHandler> handlers) |
Constructor and Description |
---|
EventDrivenConsumer(SubscribableChannel inputChannel,
MessageHandler handler) |
PollingConsumer(PollableChannel inputChannel,
MessageHandler handler) |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationEventPublishingMessageHandler
|
Modifier and Type | Class and Description |
---|---|
class |
FileWritingMessageHandler
A
MessageHandler implementation that writes the Message payload to a
file. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRemoteFileOutboundGateway<F>
Base class for Outbound Gateways that perform remote file operations.
|
Modifier and Type | Class and Description |
---|---|
class |
FileTransferringMessageHandler<F>
A
MessageHandler implementation that transfers files to a remote server. |
Modifier and Type | Class and Description |
---|---|
class |
MessageFilter
Message Handler that delegates to a
MessageSelector . |
Modifier and Type | Class and Description |
---|---|
class |
FtpOutboundGateway
Outbound Gateway for performing remote file operations via FTP/FTPS.
|
Modifier and Type | Method and Description |
---|---|
protected MessageHandler |
GroovyControlBusFactoryBean.createHandler() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageHandler
Base class for MessageHandler implementations that provides basic validation
and error handling capabilities.
|
class |
AbstractReplyProducingMessageHandler
Base class for MessageHandlers that are capable of producing replies.
|
class |
AbstractReplyProducingPostProcessingMessageHandler |
class |
BridgeHandler
A simple MessageHandler implementation that passes the request Message
directly to the output channel without modifying it.
|
class |
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. |
class |
ExpressionEvaluatingMessageHandler
A
MessageHandler that evaluates
the provided Expression expecting a void return. |
class |
LoggingHandler
MessageHandler implementation that simply logs the Message or its payload depending on the value of the
'shouldLogFullMessage' property.
|
class |
MessageHandlerChain
A composite
MessageHandler implementation that invokes a chain of
MessageHandler instances in order. |
class |
MethodInvokingMessageHandler
A
MessageHandler that invokes the specified method on the provided object. |
class |
ServiceActivatingHandler |
Modifier and Type | Method and Description |
---|---|
void |
MessageHandlerChain.setHandlers(List<MessageHandler> handlers) |
Modifier and Type | Class and Description |
---|---|
class |
HttpRequestExecutingMessageHandler
A
MessageHandler implementation that executes HTTP requests by delegating
to a RestTemplate instance. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractInternetProtocolSendingMessageHandler
Base class for all TCP/UDP MessageHandlers.
|
Modifier and Type | Class and Description |
---|---|
class |
TcpOutboundGateway
TCP outbound gateway that uses a client connection factory.
|
class |
TcpSendingMessageHandler
Tcp outbound channel adapter using a TcpConnection to
send data - if the connection factory is a server
factory, the TcpListener owns the connections.
|
Modifier and Type | Class and Description |
---|---|
class |
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. |
class |
UnicastSendingMessageHandler
A
MessageHandler implementation that maps a Message into
a UDP datagram packet and sends that to the specified host and port. |
Modifier and Type | Class and Description |
---|---|
class |
JdbcMessageHandler
A message handler that executes an SQL update.
|
class |
JdbcOutboundGateway |
class |
StoredProcMessageHandler
A message handler that executes Stored Procedures for update purposes.
|
class |
StoredProcOutboundGateway |
Modifier and Type | Class and Description |
---|---|
class |
JmsOutboundGateway
An outbound Messaging Gateway for request/reply JMS.
|
class |
JmsSendingMessageHandler
A MessageConsumer that sends the converted Message payload within a JMS Message.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SubscribableJmsChannel.subscribe(MessageHandler handler) |
boolean |
SubscribableJmsChannel.unsubscribe(MessageHandler handler) |
Modifier and Type | Class and Description |
---|---|
class |
NotificationPublishingMessageHandler |
class |
OperationInvokingMessageHandler
A
MessageHandler implementation for invoking JMX operations based on
the Message sent to its AbstractMessageHandler.handleMessage(Message) method. |
Modifier and Type | Class and Description |
---|---|
class |
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. |
Modifier and Type | Method and Description |
---|---|
protected MessageHandler |
JpaOutboundGatewayFactoryBean.createInstance() |
Modifier and Type | Class and Description |
---|---|
class |
MailSendingMessageHandler
A
MessageHandler implementation for sending mail. |
Modifier and Type | Class and Description |
---|---|
class |
MongoDbStoringMessageHandler
Implementation of
MessageHandler which writes Message payload into a MongoDb collection
identified by evaluation of the MongoDbStoringMessageHandler.collectionNameExpression . |
Modifier and Type | Method and Description |
---|---|
MessageHandler |
SimpleMessageHandlerMetrics.getMessageHandler() |
Constructor and Description |
---|
SimpleMessageHandlerMetrics(MessageHandler handler) |
Modifier and Type | Method and Description |
---|---|
boolean |
SubscribableRedisChannel.subscribe(MessageHandler handler) |
boolean |
SubscribableRedisChannel.unsubscribe(MessageHandler handler) |
Modifier and Type | Class and Description |
---|---|
class |
RedisPublishingMessageHandler |
class |
RedisQueueOutboundChannelAdapter |
class |
RedisStoreWritingMessageHandler
Implementation of
MessageHandler which writes Message data into a Redis store
identified by a key String . |
Modifier and Type | Class and Description |
---|---|
class |
RmiOutboundGateway
An outbound Messaging Gateway for RMI-based remoting.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMappingMessageRouter
Base class for all Message Routers that support mapping from arbitrary String values
to Message Channel names.
|
class |
AbstractMessageRouter
Base class for all Message Routers.
|
class |
ErrorMessageExceptionTypeRouter
A Message Router that resolves the target
MessageChannel for
messages whose payload is an Exception. |
class |
ExpressionEvaluatingRouter
A Message Router implementation that evaluates the specified SpEL
expression.
|
class |
HeaderValueRouter
A Message Router that resolves the MessageChannel from a header value.
|
class |
MethodInvokingRouter
A Message Router that invokes the specified method on the given object.
|
class |
PayloadTypeRouter
A Message Router that resolves the
MessageChannel based on the
Message's payload type. |
class |
RecipientListRouter
|
Modifier and Type | Class and Description |
---|---|
class |
SftpOutboundGateway
Outbound Gateway for performing remote file operations via SFTP.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageSplitter
Base class for Message-splitting handlers.
|
class |
DefaultMessageSplitter
The default Message Splitter implementation.
|
class |
ExpressionEvaluatingSplitter
A Message Splitter implementation that evaluates the specified SpEL
expression.
|
class |
MethodInvokingSplitter
A Message Splitter implementation that invokes the specified method
on the given object.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteStreamWritingMessageHandler
A
MessageHandler that writes a byte array to an OutputStream . |
class |
CharacterStreamWritingMessageHandler
A
MessageHandler that writes characters to a Writer . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractResponseValidator<T>
The base class for response validators used for
RequestResponseScenario s |
class |
MessageValidator
Validate a message.
|
class |
PayloadValidator<T>
Validate a message payload.
|
Modifier and Type | Method and Description |
---|---|
static MessageHandler |
TestUtils.handlerExpecting(org.hamcrest.Matcher<Message> messageMatcher) |
Modifier and Type | Class and Description |
---|---|
class |
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.
|
class |
MessageTransformingHandler
A reply-producing
MessageHandler that delegates to a
Transformer instance to modify the received Message
and sends the result to its output channel. |
Modifier and Type | Class and Description |
---|---|
class |
DirectMessageSendingMessageHandler
Simple adapter to support sending outbound direct messages ("DM"s) using Twitter.
|
class |
StatusUpdatingMessageHandler
MessageHandler for sending regular status updates as well as 'replies' or 'mentions'.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractWebServiceOutboundGateway
Base class for outbound Web Service-invoking Messaging Gateways.
|
class |
MarshallingWebServiceOutboundGateway
An outbound Messaging Gateway for invoking Web Services that also supports
marshalling and unmarshalling of the request and response messages.
|
class |
SimpleWebServiceOutboundGateway
An outbound Messaging Gateway for invoking a Web Service.
|
Modifier and Type | Class and Description |
---|---|
class |
XPathRouter
Message Router that uses
XPathExpression evaluation to determine channel names. |
Modifier and Type | Class and Description |
---|---|
class |
XPathMessageSplitter
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractXmppConnectionAwareMessageHandler |
Modifier and Type | Class and Description |
---|---|
class |
ChatMessageSendingMessageHandler
MessageHandler that sends an XMPP Chat Message.
|
class |
PresenceSendingMessageHandler
MessageHandler that publishes updated Presence values for a given XMPP connection.
|
Copyright © 2017. All rights reserved.