|
Spring Integration | ||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
MessageStore.AbstractCorrelatingMessageHandlerMessageDispatcher implementations.FileInfo; provides a setter
for the remote directory and a generic toString implementation.FileListFilter whose criteria can be
evaluated against each File in isolation.SessionFactory used to acquire Session instances.
MessageGroupStore and MessageStoreMailReceiver implementations.MessageChannel implementations providing common
properties such as the channel name.MessageProcessor.Transformer implementations that modify the payload
of a Message.Pattern)MessageHandler advice classes.RequestResponseScenariosMessageProcessor for scripting implementations to extend.MessageChannel that invokes the subscribed
handler(s) by delegating to a MessageDispatcher.TcpConnection.Transformer implementations.MessageSelector implementations.XPathExpression evaluates to true
XPathExpression matches the regex.
XPathExpression is equal to the valueToTestFor.
FileListFilter that always returns true.CollectionFilter that remembers the elements passed in
the previous invocation in order to avoid returning those elements more than once.FileListFilter that passes files only one time.ResourceHolder instance
TcpListener, this
method is called each time a new connection is made.
DataSource and
JdbcChannelMessageStore.setChannelMessageStoreQueryProvider(ChannelMessageStoreQueryProvider)).
SimpleJdbcCallOperations
and ensures the appropriate SqlParameterSourceFactory is defined
when ProcedureParameter are passed in.
MessagingTemplate to send downstream.
AbstractCorrelatingMessageHandler.@Aggregator annotation.HeaderMapper
but parameterized with MessageProperties.ApplicationEvents within messages.MessageHandler that publishes each Message it receives as
a MessagingEvent.MessageSource implementation that retrieves the current
value of a JMX attribute each time AbstractMessageSource.receive() is invoked.ChannelResolver implementation based on a Spring BeanFactory.BeanFactoryChannelResolver class.
BeanFactoryChannelResolver class.
SqlParameterSourceFactory which creates an SqlParameterSource to
reference bean properties in its input.MessageSelector.MessageSelector supporting
multiple namespaces.
MessageSelector supporting a single namespace.
MessageSelector with no namespace support.
MessageSelector using the
provided XPathExpression.
ByteArrayLengthHeaderSerializer.HEADER_SIZE_INT
InputStream.MessageHandler that writes a byte array to an OutputStream.MessageHandler implementation that writes to a GemFire Region.SessionFactory implementation that caches Sessions for reuse without
requiring reconnection each time the Session is retrieved from the factory.ConfigAttributes for secured channel
send and receive operations.Messages being sent-to and/or received-from a
MessageChannel.ChannelInterceptor with no-op method implementations so that
subclasses do not have to implement all of the interface's methods.ChannelSecurityInterceptor.JdbcChannelMessageStore to provide database-specific queries.Messages from one or more
QueueChannels.MessageChannel.BeanPostProcessor that proxies MessageChannels to apply a ChannelSecurityInterceptor.SecurityMetadataSource implementation for secured MessageChannels.Readers.MessageHandler that writes characters to a Writer.Messages from this channel.
UnsupportedOperationException
FileListFilter that predicates its matches against any of many
configured FileListFilter.TransactionInterceptor
with "transactionManager" and other "transactionDefinition" properties.
DefaultTransactionAttribute
with provided "transactionDefinition" properties.
Region.UUIDConverter.getUUID(Object).
ProcedureParameter to
a Map containing only expression parameters.
ProcedureParameter to
a Map containing only static parameters.
CorrelationStrategy.SqlParameterSource.
ParameterSource.
ServerSocket.
Socket.
Source instance for payload
StandardEvaluationContext with a MapAccessor in its
property accessor property.
StandardEvaluationContext with a MapAccessor in its
property accessor property and the supplied BeanResolver in its
beanResolver property.
StandardEvaluationContext with a MapAccessor in its
property accessor property and the supplied ConversionService in its
conversionService property.
StandardEvaluationContext with a MapAccessor in its
property accessor property, the supplied BeanResolver in its
beanResolver property, and the supplied ConversionService in its
conversionService property.
BeanFactoryResolver, extracts ConversionService and delegates to
ExpressionUtils.createStandardEvaluationContext(BeanResolver, ConversionService)
AmqpHeaderMapper.ConfigAttributes for secured channel
send and receive operations based on simple String values.HeaderMapper implementation for HTTP.JmsHeaderMapper.LockRegistry which uses Masked Hashcode algorithm to obtain locks.MultipartFileReader implementation that reads the MultipartFile
content directly into a new MultipartFile instance that is not restricted
to the HTTP request scope.SftpSession instances.HeaderMapper implementation for mapping to and from a SoapHeader.ServerSocket and
Socket.SSLServerSocket and
SSLSocket.TcpNioConnectionSupport for non-SSL
NIO connections.TcpNioConnectionSupport for SSL
NIO connections.TcpSocketSupport; makes no
changes to sockets.TcpSSLContextSupport; uses a
'TLS' (by default) SSLContext, initialized with 'JKS'
keystores, managed by 'SunX509' Key and Trust managers.TransactionSynchronizationFactory which takes an instance of
TransactionSynchronizationProcessor allowing you to create a TransactionSynchronization
using {DefaultTransactionSynchronizationFactory.create(Object) method.XmlPayloadConverter.XmppHeaderMapper.MessageHandler that is capable of delaying the continuation of a
Message flow based on the presence of a delay header on an inbound Message
or a default delay value configured on this handler.MessageGroup
to store delayed Messages in the MessageGroupStore.
RoundRobinLoadBalancingStrategy
LoadBalancingStrategy.
MessageHandler. callback.execute()
invokes the handler method and returns its result, or null.
SourceFactory implementation which supports creation of a DOMSource
from a Document, File or String payload.AbstractPollingEndpoint.receiveMessage() and AbstractPollingEndpoint.handleMessage(Message) instead,
to separate the concerns of retrieving and processing a message.
Consider refactoring now rather than waiting for 3.0.
JdbcChannelMessageStore
means the channel identifier.
Expression that delegates to an ExpressionSource
for resolving the actual Expression instance per-invocation at runtime.TaskExecutor implementation that wraps an existing Executor
instance in order to catch any exceptions.Throwable payload.MessageChannel for
messages whose payload is an Exception..$[]^*+{}()\?|MessageHandler implementation to a SubscribableChannel.Message is
available to extract ProcedureParameter values from it.
Message is
available to extract ProcedureParameter values from it.
MessageChannel that delegates to an instance of
UnicastingDispatcher which in turn delegates all dispatching
invocations to an Executor.Executor when dispatching Messages.
LoadBalancingStrategy that
delegates to the provided Executor when dispatching Messages.
MessageHandler instances to handle a message as a SpEL expression.CorrelationStrategy implementation that evaluates an expression.MessageGroupProcessor implementation that evaluates a SpEL expression.MessageHandler that evaluates
the provided Expression expecting a void return.MessageProcessor implementation that evaluates a SpEL expression
with the Message itself as the root object within the evaluation context.ExpressionEvaluatingMessageProcessor for the given expression.
ExpressionEvaluatingMessageProcessor for the given expression
and expected type for its evaluation result.
ReleaseStrategy that evaluates an expression.MessageHandlers.MessageSelector implementation that evaluates a SpEL expression.SqlParameterSourceFactory which creates an SqlParameterSource that evaluates
Spring EL expressions.TransactionSynchronizationFactory
allows you to configure SpEL expressions, with their execution being coordinated (synchronized) with a
transaction - see TransactionSynchronization.TcpConnections
that can iterate over a connection from each factory until the write
succeeds or the list is exhausted.MessageSource will produce individual
SyndEntrys for a feed identified with the 'feedUrl' attribute.MultipartFileReader implementation that copies the MulitpartFile's
content to a new temporary File in the specified directory.FileCopyingMultipartFileReader that creates temporary
Files in the default temporary directory.
FileCopyingMultipartFileReader that creates temporary
Files in the given directory.
MessageSource that creates messages from a file system directory.PriorityBlockingQueue
ordered with the passed in Comparator
The size of the queue used should be large enough to hold all the files
in the input directory in order to sort all of them, so restricting the
size of the queue is mutually exclusive with ordering.
MessageHandler implementation that transfers files to a remote server.MessageHandler implementation that writes the Message payload to a
file.FileWritingMessageHandler.destinationDirectoryExpression using
a LiteralExpression.
FileWritingMessageHandler.destinationDirectoryExpression.
FileWritingMessageHandlers.@Filter.MethodFilter implementation that will always return
the same Method instance within a single-element list if it is
present in the candidate list.Message instance pre-populated with all of the headers copied from the
provided message.
FileInfo implementation for FTP/FTPS.AbstractInboundFileSynchronizer for FTP.SessionFactory used to acquire Session instances.
MessageSource implementation for FTP.AbstractRegexPatternFileListFilter for FTP.Session for FTP.AbstractSimplePatternFileListFilter for FTP.MessageStore and
MessageGroupStoreSearchTerm
IntegrationObjectSupport.componentName field.
AbstractConnectionFactory.setSingleUse(boolean) was called with
true, a new connection is returned; otherwise a single connection is
reused for all requests while the connection remains open.
TcpSendingMessageHandler.obtainConnection(Message).
TODO: remove in 3.0
ConversionService bean whose name is "integrationConversionService" if available.
PollerMetadata bean if available.
MessageChannel bean whose name is "errorChannel".
FileExistsMode.
next() invocations.
Set of this dispatcher's handlers.
CacheStats}) for the
StoredProcExecutor.jdbcCallOperationsCache, which is used to store
instances of SimpleJdbcCallOperations.
CacheStats}) for the
StoredProcExecutor.jdbcCallOperationsCache.
BeanDefinitionBuilder for the class JpaExecutor.
ManagedList of BeanDefinitions containing parsed
JPA Parameters.
MessageGroupStore.addMessageToGroup(Object, Message) with this group id.
MessagingTemplate for subclasses.
MessagingTemplate access for subclasses.
MetadataStore bean whose name is "metadataStore".
BeanDefinitionBuilder for the class JpaExecutor
that is specific for JPA Outbound Gateways.
AbstractConnectionFactory.setTaskExecutor(Executor).
TaskScheduler bean whose name is "taskScheduler".
ServerSocketFactory to be used to
create new ServerSockets.
SocketFactory to be used to
create new Sockets.
BeanDefinitionBuilder for the class StoredProcExecutor.
TaskScheduler bean whose name is "taskScheduler" if available.
GroovyCommandMessageProcessor that will use the DefaultScriptVariableGenerator.
GroovyCommandMessageProcessor that will use the provided ScriptVariableGenerator.
GroovyCommandMessageProcessor that will use the DefaultScriptVariableGenerator
and provided Binding.
GroovyCommandMessageProcessor that will use the provided ScriptVariableGenerator and Binding.
MessageHandler instances to handle a message as a Groovy Script.ScriptSource that will use a
DefaultScriptVariableGenerator.
ScriptSource that will use the provided
ScriptVariableGenerator.
SqlParameterSourceFactory.
DelayHandler.releaseMessageAfterDelay(org.springframework.integration.Message, long) and DelayHandler.DelayedMessageWrapper).
maxNumberOfFiles
elements from a directory listing.CorrelationStrategy.MessageHeaders to and from other
types of objects.MessageHeaders of a Message containing any entry
or multiple that match?MessageHandler implementation that executes HTTP requests by delegating
to a RestTemplate instance.Controller interface to be used with a DispatcherServlet front
controller.MailReceiver implementation for receiving mail messages from a
mail server that supports the IMAP protocol.Message.TaskScheduler and ConversionService instances.ResourceHolder which holds an instance of the current Message
and the synchronization resource