Package | Description |
---|---|
org.springframework.integration.aggregator |
Provides classes related to message aggregation.
|
org.springframework.integration.amqp.channel |
Provides classes related to AMQP-backed channels.
|
org.springframework.integration.amqp.outbound |
Provides classes supporting outbound endpoints.
|
org.springframework.integration.aop |
Provides classes to support message publication using AOP.
|
org.springframework.integration.channel |
Provides classes representing various channel types.
|
org.springframework.integration.channel.interceptor |
Provides classes related to channel interception.
|
org.springframework.integration.config |
Base package for configuration.
|
org.springframework.integration.context |
Provides classes relating to application context configuration.
|
org.springframework.integration.core |
Provides core classes.
|
org.springframework.integration.endpoint |
Provides core classes related to Endpoints.
|
org.springframework.integration.file.config |
Provides classes for configuration - parsers, namespace handlers, factory beans.
|
org.springframework.integration.filter |
Provides classes supporting the filter pattern.
|
org.springframework.integration.gateway |
Provides classes supporting messaging gateways.
|
org.springframework.integration.handler |
Provides classes implementing various types of message handler.
|
org.springframework.integration.handler.advice |
Provides classes that are used to advise
MessageHandler s with
cross-cutting concerns. |
org.springframework.integration.ip.tcp |
Base package for TCP Support.
|
org.springframework.integration.jms |
Base package for JMS Support.
|
org.springframework.integration.jpa.outbound |
Provides Spring Integration components for doing outbound operations.
|
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.inbound |
Provides classes supporting inbound endpoints.
|
org.springframework.integration.rmi |
Base package for RMI support.
|
org.springframework.integration.router |
Provides classes supporting the router pattern.
|
org.springframework.integration.security.channel |
Provides classes related to secured channels.
|
org.springframework.integration.support |
Base core support package.
|
org.springframework.integration.support.channel |
Provides classes supporting channel resolution.
|
org.springframework.integration.syslog.config |
Provides classes for configuration - parsers, namespace handlers, factory beans.
|
org.springframework.integration.test.util |
Provides various test utilities, for example
TestUtils provides convenience
helpers to easily retrieve private bean properties. |
org.springframework.integration.transaction |
Provides classes supporting the use of transactions and
pseudo transactions in Spring Integration applications.
|
org.springframework.integration.transformer |
Contains core-implementation of various Transformers which includes Enrichers
and Filters.
|
org.springframework.integration.ws |
Provides several inbound and outbound Web Service components.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractCorrelatingMessageHandler.setDiscardChannel(MessageChannel discardChannel) |
void |
AbstractCorrelatingMessageHandler.setOutputChannel(MessageChannel outputChannel) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAmqpChannel |
class |
PointToPointSubscribableAmqpChannel |
class |
PollableAmqpChannel
A
PollableChannel implementation that is backed by an AMQP Queue. |
class |
PublishSubscribeAmqpChannel |
Modifier and Type | Method and Description |
---|---|
void |
AmqpOutboundEndpoint.setConfirmAckChannel(MessageChannel ackChannel) |
void |
AmqpOutboundEndpoint.setConfirmNackChannel(MessageChannel nackChannel) |
void |
AmqpOutboundEndpoint.setReturnChannel(MessageChannel returnChannel) |
Modifier and Type | Method and Description |
---|---|
void |
MessagePublishingInterceptor.setDefaultChannel(MessageChannel defaultChannel) |
void |
PublisherAnnotationBeanPostProcessor.setDefaultChannel(MessageChannel defaultChannel)
Set the default channel where Messages should be sent if the annotation
itself does not provide a channel.
|
void |
PublisherAnnotationAdvisor.setDefaultChannel(MessageChannel defaultChannel) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageChannel
Base class for
MessageChannel implementations providing common
properties such as the channel name. |
class |
AbstractPollableChannel
Base class for all pollable channels.
|
class |
AbstractSubscribableChannel
Base implementation of
MessageChannel that invokes the subscribed
handler(s) by delegating to a MessageDispatcher . |
class |
DirectChannel
A channel that invokes a single subscriber for each sent Message.
|
class |
ExecutorChannel
An implementation of
MessageChannel that delegates to an instance of
UnicastingDispatcher which in turn delegates all dispatching
invocations to an Executor . |
class |
NullChannel
A channel implementation that essentially behaves like "/dev/null".
|
class |
PriorityChannel
A message channel that prioritizes messages based on a
Comparator . |
class |
PublishSubscribeChannel
A channel that sends Messages to each of its subscribers.
|
class |
QueueChannel
Simple implementation of a message channel.
|
class |
RendezvousChannel
A zero-capacity version of
QueueChannel that delegates to a
SynchronousQueue internally. |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
DefaultHeaderChannelRegistry.channelNameToChannel(String name) |
Modifier and Type | Method and Description |
---|---|
Message<?> |
ChannelInterceptor.postReceive(Message<?> message,
MessageChannel channel)
Invoked immediately after a Message has been retrieved but before
it is returned to the caller.
|
Message<?> |
AbstractMessageChannel.ChannelInterceptorList.postReceive(Message<?> message,
MessageChannel channel) |
void |
ChannelInterceptor.postSend(Message<?> message,
MessageChannel channel,
boolean sent)
Invoked immediately after the send invocation.
|
void |
AbstractMessageChannel.ChannelInterceptorList.postSend(Message<?> message,
MessageChannel channel,
boolean sent) |
boolean |
ChannelInterceptor.preReceive(MessageChannel channel)
Invoked as soon as receive is called and before a Message is
actually retrieved.
|
boolean |
AbstractMessageChannel.ChannelInterceptorList.preReceive(MessageChannel channel) |
Message<?> |
ChannelInterceptor.preSend(Message<?> message,
MessageChannel channel)
Invoked before the Message is actually sent to the channel.
|
Message<?> |
AbstractMessageChannel.ChannelInterceptorList.preSend(Message<?> message,
MessageChannel channel) |
void |
MessagePublishingErrorHandler.setDefaultErrorChannel(MessageChannel defaultErrorChannel) |
Modifier and Type | Method and Description |
---|---|
Message<?> |
ChannelInterceptorAdapter.postReceive(Message<?> message,
MessageChannel channel) |
void |
ChannelInterceptorAdapter.postSend(Message<?> message,
MessageChannel channel,
boolean sent) |
boolean |
ChannelInterceptorAdapter.preReceive(MessageChannel channel) |
Message<?> |
ChannelInterceptorAdapter.preSend(Message<?> message,
MessageChannel channel) |
Message<?> |
WireTap.preSend(Message<?> message,
MessageChannel channel)
Intercept the Message and, if accepted by the
MessageSelector ,
send it to the secondary target. |
Message<?> |
MessageSelectingInterceptor.preSend(Message<?> message,
MessageChannel channel) |
Constructor and Description |
---|
WireTap(MessageChannel channel)
Create a new wire tap with no
MessageSelector . |
WireTap(MessageChannel channel,
MessageSelector selector)
Create a new wire tap with the provided
MessageSelector . |
Modifier and Type | Method and Description |
---|---|
void |
RouterFactoryBean.setDefaultOutputChannel(MessageChannel defaultOutputChannel) |
void |
FilterFactoryBean.setDiscardChannel(MessageChannel discardChannel) |
void |
ConsumerEndpointFactoryBean.setInputChannel(MessageChannel inputChannel) |
void |
AbstractSimpleMessageHandlerFactoryBean.setOutputChannel(MessageChannel outputChannel) |
void |
SourcePollingChannelAdapterFactoryBean.setOutputChannel(MessageChannel outputChannel) |
Modifier and Type | Method and Description |
---|---|
static MessageChannel |
IntegrationContextUtils.getErrorChannel(org.springframework.beans.factory.BeanFactory beanFactory)
Return the
MessageChannel bean whose name is "errorChannel". |
Modifier and Type | Interface and Description |
---|---|
interface |
PollableChannel
Interface for Message Channels from which Messages may be actively received through polling.
|
interface |
SubscribableChannel
Interface for any MessageChannel implementation that accepts subscribers.
|
Modifier and Type | Method and Description |
---|---|
protected MessageChannel |
MessagingTemplate.resolveChannelName(String channelName)
Resolve the given channel name into a
MessageChannel ,
via this template's ChannelResolver if available. |
Modifier and Type | Method and Description |
---|---|
Future<?> |
AsyncMessagingTemplate.asyncConvertAndSend(MessageChannel channel,
Object object) |
Future<?> |
AsyncMessagingOperations.asyncConvertAndSend(MessageChannel channel,
Object message) |
<R> Future<R> |
AsyncMessagingTemplate.asyncConvertSendAndReceive(MessageChannel channel,
Object request) |
<R> Future<R> |
AsyncMessagingOperations.asyncConvertSendAndReceive(MessageChannel channel,
Object request) |
<R> Future<R> |
AsyncMessagingTemplate.asyncConvertSendAndReceive(MessageChannel channel,
Object request,
MessagePostProcessor requestPostProcessor) |
<R> Future<R> |
AsyncMessagingOperations.asyncConvertSendAndReceive(MessageChannel channel,
Object request,
MessagePostProcessor requestPostProcessor) |
Future<?> |
AsyncMessagingTemplate.asyncSend(MessageChannel channel,
Message<?> message) |
Future<?> |
AsyncMessagingOperations.asyncSend(MessageChannel channel,
Message<?> message) |
Future<Message<?>> |
AsyncMessagingTemplate.asyncSendAndReceive(MessageChannel channel,
Message<?> requestMessage) |
Future<Message<?>> |
AsyncMessagingOperations.asyncSendAndReceive(MessageChannel channel,
Message<?> requestMessage) |
<T> void |
MessagingOperations.convertAndSend(MessageChannel channel,
T message)
Send the given object to the specified channel, converting the object
to a message with a configured MessageConverter.
|
<T> void |
MessagingTemplate.convertAndSend(MessageChannel channel,
T object) |
<T> void |
MessagingOperations.convertAndSend(MessageChannel channel,
T message,
MessagePostProcessor postProcessor)
Send the given object to the specified channel, converting the object
to a message with a configured MessageConverter.
|
<T> void |
MessagingTemplate.convertAndSend(MessageChannel channel,
T object,
MessagePostProcessor postProcessor) |
Object |
MessagingOperations.convertSendAndReceive(MessageChannel channel,
Object request)
Send the given request object to the specified channel, converting the object
to a message with a configured MessageConverter.
|
Object |
MessagingTemplate.convertSendAndReceive(MessageChannel channel,
Object request) |
Object |
MessagingOperations.convertSendAndReceive(MessageChannel channel,
Object request,
MessagePostProcessor requestPostProcessor)
Send the given request object to the specified channel, converting the object
to a message with a configured MessageConverter.
|
Object |
MessagingTemplate.convertSendAndReceive(MessageChannel channel,
Object request,
MessagePostProcessor requestPostProcessor) |
<P> void |
MessagingOperations.send(MessageChannel channel,
Message<P> message)
Send a message to the specified channel.
|
<P> void |
MessagingTemplate.send(MessageChannel channel,
Message<P> message) |
Message<?> |
MessagingOperations.sendAndReceive(MessageChannel channel,
Message<?> requestMessage)
Send a message to the specified channel and receive a reply.
|
Message<?> |
MessagingTemplate.sendAndReceive(MessageChannel channel,
Message<?> requestMessage) |
void |
MessagingTemplate.setDefaultChannel(MessageChannel defaultChannel)
Specify the default MessageChannel to use when invoking the send and/or
receive methods that do not expect a channel parameter.
|
void |
MessageProducer.setOutputChannel(MessageChannel outputChannel)
Specify the MessageChannel to which produced Messages should be sent.
|
Constructor and Description |
---|
MessagingTemplate(MessageChannel defaultChannel)
Create a MessagingTemplate with the given default channel.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageProducerSupport.setErrorChannel(MessageChannel errorChannel) |
void |
SourcePollingChannelAdapter.setOutputChannel(MessageChannel outputChannel)
Specify the
MessageChannel where Messages should be sent. |
void |
MessageProducerSupport.setOutputChannel(MessageChannel outputChannel) |
Modifier and Type | Method and Description |
---|---|
void |
FileTailInboundChannelAdapterFactoryBean.setErrorChannel(MessageChannel errorChannel) |
void |
FileTailInboundChannelAdapterFactoryBean.setOutputChannel(MessageChannel outputChannel) |
Modifier and Type | Method and Description |
---|---|
void |
MessageFilter.setDiscardChannel(MessageChannel discardChannel)
Specify a channel where rejected Messages should be sent.
|
Modifier and Type | Method and Description |
---|---|
void |
GatewayProxyFactoryBean.setDefaultReplyChannel(MessageChannel defaultReplyChannel)
Set the default reply channel.
|
void |
GatewayProxyFactoryBean.setDefaultRequestChannel(MessageChannel defaultRequestChannel)
Set the default request channel.
|
void |
GatewayProxyFactoryBean.setErrorChannel(MessageChannel errorChannel)
Set the error channel.
|
void |
MessagingGatewaySupport.setErrorChannel(MessageChannel errorChannel)
Set the error channel.
|
void |
MessagingGatewaySupport.setReplyChannel(MessageChannel replyChannel)
Set the reply channel.
|
void |
MessagingGatewaySupport.setRequestChannel(MessageChannel requestChannel)
Set the request channel.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageHandlerChain.setOutputChannel(MessageChannel outputChannel) |
void |
AbstractReplyProducingMessageHandler.setOutputChannel(MessageChannel outputChannel) |
Modifier and Type | Method and Description |
---|---|
void |
ExpressionEvaluatingRequestHandlerAdvice.setFailureChannel(MessageChannel failureChannel) |
void |
ExpressionEvaluatingRequestHandlerAdvice.setSuccessChannel(MessageChannel successChannel) |
Constructor and Description |
---|
ErrorMessageSendingRecoverer(MessageChannel channel) |
Modifier and Type | Method and Description |
---|---|
void |
TcpOutboundGateway.setReplyChannel(MessageChannel replyChannel)
Specify the Spring Integration reply channel.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractJmsChannel |
class |
PollableJmsChannel |
class |
SubscribableJmsChannel |
Modifier and Type | Method and Description |
---|---|
void |
ChannelPublishingJmsMessageListener.setErrorChannel(MessageChannel errorChannel) |
void |
ChannelPublishingJmsMessageListener.setReplyChannel(MessageChannel replyChannel) |
void |
JmsOutboundGateway.setReplyChannel(MessageChannel replyChannel)
Specify the Spring Integration reply channel.
|
void |
ChannelPublishingJmsMessageListener.setRequestChannel(MessageChannel requestChannel) |
Modifier and Type | Method and Description |
---|---|
void |
JpaOutboundGatewayFactoryBean.setOutputChannel(MessageChannel outputChannel) |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
DirectChannelMetrics.getMessageChannel() |
Modifier and Type | Method and Description |
---|---|
protected Object |
PollableChannelMetrics.doInvoke(org.aopalliance.intercept.MethodInvocation invocation,
String method,
MessageChannel channel) |
protected Object |
DirectChannelMetrics.doInvoke(org.aopalliance.intercept.MethodInvocation invocation,
String method,
MessageChannel channel) |
Constructor and Description |
---|
DirectChannelMetrics(MessageChannel messageChannel,
String name) |
PollableChannelMetrics(MessageChannel messageChannel,
String name) |
Modifier and Type | Class and Description |
---|---|
class |
SubscribableRedisChannel |
Modifier and Type | Method and Description |
---|---|
void |
RedisQueueMessageDrivenEndpoint.setErrorChannel(MessageChannel errorChannel) |
Modifier and Type | Method and Description |
---|---|
void |
RmiOutboundGateway.setReplyChannel(MessageChannel replyChannel) |
void |
RmiInboundGateway.setRequestChannel(MessageChannel requestChannel)
Specify the request channel where messages will be sent.
|
Modifier and Type | Method and Description |
---|---|
MessageChannel |
RecipientListRouter.Recipient.getChannel() |
Modifier and Type | Method and Description |
---|---|
protected abstract Collection<MessageChannel> |
AbstractMessageRouter.determineTargetChannels(Message<?> message)
Subclasses must implement this method to return a Collection of zero or more
MessageChannels to which the given Message should be routed.
|
protected Collection<MessageChannel> |
AbstractMappingMessageRouter.determineTargetChannels(Message<?> message) |
protected Collection<MessageChannel> |
RecipientListRouter.determineTargetChannels(Message<?> message) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMessageRouter.setDefaultOutputChannel(MessageChannel defaultOutputChannel)
Set the default channel where Messages should be sent if channel resolution
fails to return any channels.
|
Modifier and Type | Method and Description |
---|---|
void |
RecipientListRouter.setChannels(List<MessageChannel> channels)
Set the channels for this router.
|
Constructor and Description |
---|
Recipient(MessageChannel channel) |
Recipient(MessageChannel channel,
MessageSelector selector) |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
ChannelInvocation.getChannel() |
Modifier and Type | Method and Description |
---|---|
MessageBuilder<T> |
MessageBuilder.setErrorChannel(MessageChannel errorChannel) |
MessageBuilder<T> |
MessageBuilder.setReplyChannel(MessageChannel replyChannel) |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
HeaderChannelRegistry.channelNameToChannel(String name)
Converts the channel name back to a
MessageChannel (if it is
registered). |
MessageChannel |
ChannelResolver.resolveChannelName(String channelName)
Return the MessageChannel for the given name.
|
MessageChannel |
BeanFactoryChannelResolver.resolveChannelName(String name) |
Modifier and Type | Method and Description |
---|---|
void |
SyslogReceivingChannelAdapterFactoryBean.setErrorChannel(MessageChannel errorChannel) |
void |
SyslogReceivingChannelAdapterFactoryBean.setOutputChannel(MessageChannel outputChannel) |
Modifier and Type | Method and Description |
---|---|
void |
TestUtils.TestApplicationContext.registerChannel(String channelName,
MessageChannel channel) |
Modifier and Type | Method and Description |
---|---|
void |
ExpressionEvaluatingTransactionSynchronizationProcessor.setAfterCommitChannel(MessageChannel afterCommitChannel) |
void |
ExpressionEvaluatingTransactionSynchronizationProcessor.setAfterRollbackChannel(MessageChannel afterRollbackChannel) |
void |
ExpressionEvaluatingTransactionSynchronizationProcessor.setBeforeCommitChannel(MessageChannel beforeCommitChannel) |
Modifier and Type | Method and Description |
---|---|
Message<?> |
MessageTransformingChannelInterceptor.postReceive(Message<?> message,
MessageChannel channel)
Deprecated.
|
Message<?> |
MessageTransformingChannelInterceptor.preSend(Message<?> message,
MessageChannel channel)
Deprecated.
|
void |
ContentEnricher.setReplyChannel(MessageChannel replyChannel)
Sets the content enricher's reply channel.
|
void |
ContentEnricher.setRequestChannel(MessageChannel requestChannel)
Sets the content enricher's request channel.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractWebServiceOutboundGateway.setReplyChannel(MessageChannel replyChannel) |
Copyright © 2015. All rights reserved.