|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
ChannelFactory
implementations.MessageDispatcher
implementations.JmsTemplate
.MailHeaderGenerators
.MessageBarrier
.MessageBarrier
-based MessageHandlers.MessageChannel
implementations providing common
properties such as the channel name and DispatcherPolicy
.MessageHandler
that may act as an adapter
by invoking a "plain" (not Message-aware) method for a given target object.MessageHandler
adapter for the provided object and method.MonitoringStrategy
interface.MessageHandler
adapters.MessageHandler
adapters.AbstractMessageBarrierHandler
that waits for a complete
group of Messages
to arrive and then delegates to an
Aggregator
to combine them into a single Message
.Messages
into a
single Message
.@Aggregator
and for 'aggregator
' elements that include a 'method
' attribute
(e.g.AggregatorAdapter
for methods that aggregate messages.MessagePublishingInterceptor
that resolves the channel from the
publisher annotation of the invoked method.ApplicationEvents
within messages.MessagingEvents
.MessageExchangeTemplate
.PollableSource
and provides a timeout-aware receive method.MessageTarget
and provides a timeout-aware send method.MessageCreator
implementation for messages with a byte array payload.InputStream
.OutputStream
.CafeDemo
.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.ChannelInterceptor
instance with any
AbstractMessageChannel
with a name matching the provided patternMessageListener
implementation that converts the received JMS
message into a Spring Integration message and then sends that to a channel.Messages
from one or more
PollableChannels
.ChannelRegistry
.Readers
.Writer
.Messages
from this channel.
@CompletionStrategy
and for 'completion-strategy
' elements that include a 'method
'
attribute (e.g.ConcurrencyPolicy
settings for a @MessageEndpoint
.EndpointInterceptor
implementation that delegates to a
TaskExecutor
for concurrent, asynchronous message handling.Source
instance for payload
ApplicationContext
or else the default implementation
(QueueChannelFactory).ChannelRegistry
.EndpointRegistry
.MessageBus
.MonitoringStrategy
HeaderMapper
implementation for JMS Messages
.MailHeaderGenerator
.MessageCreator
that uses the provide value
as the Message's
payload.DefaultMessageHandler
for the provided object and method.MessageMapper
that returns the
Message's
payload.MethodInvoker
to be used when the actual Method
reference is known.target(s)
in
the sender's thread (returning after at most one handles the message).ChannelFactory
for creating DirectChannel
instances.SourceFactory
implementation which supports creation of a
DOMSource
from a Document
or String
payload.EndpointInterceptors
.Throwable
.Throwable
payload.MessageCreator
that creates Message
instances with the
absolute path to the File
as payload.Folder
and ensures thread safetyMessage
instance pre-populated with
all of the headers copied from the provided message.
Message
instance with the provided payload.
FTPClient
.FTPClient
instances.MessageExchangeTemplate
for performing
send and receive operations across channels.
null
.
@Handler
annotation.MessageConverter
implementation that delegates to an existing
converter as well as an implementation of MessageHeaderMapper
.MessageHandler
implementation that delegates to an instance
of the HeaderTransformer
strategy interface to modify the
header values of a Message
.MonitoringStrategy
interface that uses the IMAP IDLE command for asynchronous message
detection.MessageSource
to a MessageChannel
.MimeMessage
to a Message
Message
to an Object.
Messages
based upon a condition that is met when a
Message
arrives.MessageBus
.MessageBusAware
beans with a
reference to the MessageBus
.Message Bus
.MessageBusInterceptor
.Message
from an Object.PollableSource
s and MessageTarget
s.MessageHandlers
.MessageHeader
.Message
.Message
instances or payloads.Message
to an Object.ErrorHandler
implementation that sends an ErrorMessage
to a
MessageChannel
.ChannelInterceptor
that
delegates to a list of MessageSelectors
to decide
whether a Message
should be accepted on the MessageChannel
.Comparator
implementation based on the 'sequence number'
property of a Message's
header.Messages
.ChannelInterceptor
that delegates to a MessageStore
.Messages
can be sent.ChannelInterceptor
which invokes a MessageHandler
when either sending-to or receiving-from a channel.BeanPostProcessor
implementation that processes method-level
messaging annotations such as @Handler, @MessageSource, and @MessageTarget.ApplicationEvent
that wraps a Message
.Messages
and MessagingEvents
.MessageExchangeTemplate
and exposing setter methods for
configuring request and reply MessageChannels
.MessageChannels
.MethodInvoker
to be used when only the method name is known.MessageChannel
to a MessageTarget
.MessageChannel
based on the
Message's
payload type.MessageSelector
implementation that checks the type of the
Message
payload.@Pollable
.Messages
that can be polled.@MessageEndpoint
annotation in order to provide the
polling metadata and scheduling information for that endpoint.PollableSource
.
MessageSource
implementation which delegates to a
MonitoringStrategy
to poll a mailbox.MonitoringStrategy
interface that uses a simple polling mechanism.MonitoringStrategy
interface that uses a simple polling mechanism suitable for POP3
servers.MessageSelector
,
send it to the secondary target.
PriorityChannel.MessagePriorityComparator
.ChannelFactory
for creating PriorityChannel
instances.TaskScheduler
that understands
PollingSchedules
and delegates to
a ScheduleServiceProvider
instance.BeanPostProcessor
that adds a message publishing interceptor when
it discovers annotated methods.TaskExecutor
to publish its Messages.
Messages
that are not accepted by the provided selector.
ScheduleServiceProvider
.JobListener
used for re-scheduling a fixed delay task, as Quartz does
not support fixed delay tasks out of the box.Job
, allowing running Quartz jobs top be manipulated via
the ScheduledFuture
interface.ChannelFactory
, which will create instances of a
QueueChannel
.AsyncMessage
from the provided source.
null
if no message is available.
null
,
send it to the given target.
MultiChannelRouter
that routes to a statically
configured list of recipients.FilenameFilter
implementation for matching against
a regular expression Pattern
.QueueChannel
that delegates to a
SynchronousQueue
internally.ChannelFactory
for creating RendezvousChannel
instances.AbstractMessageBarrierHandler
that waits for a group of
Messages
to arrive and re-sends them in order, sorted
by their sequenceNumber
.Result
possibly taking into account the
provided message payload instance.Document
from a Result
payload.Result
to an instance of String
Supports StringResult
and DOMResult
MessageStore
implementation whose get
and
remove
methods block until a message is available.MessageStore
so that its
retrieval methods will block.
SimpleMessageStore
so that its
retrieval methods will block.
null
messages in the queue.MessageChannel
for messages
whose payload is an Exception.@Router
.MessageHandler
adapter for router methods.TaskScheduler
.Folder.getMessages()
.
SecurityContext
propagation behaviour for the parent
element channel, and creates a SecurityEnforcingChannelInterceptor
to
control send and receive access if send-access and/or receive-access is
specified.SecurityContext
associated with the current thread
(if any) by adding it to the header of sent messages.AccessDecisionManager
to
enforce the security on the send and receive calls of the MessageChannel
.SecurityContext
propagation behaviour.Message
to this target.
AsyncMessage
.
CompletionStrategy
that simply compares the
current size of the message list to the expected 'sequenceSize' according to
the first Message
in the list.SourceFactory
ResultFactory
and SourceFactory
even for
directly supported payloads such as String
and Document
DELETED
after they have been
read.
MessageCreator
to use when creating a message from the
return value Object.
TaskExecutor
for invoking the target endpoints.
TaskScheduler
to use for scheduling message dispatchers.
MessageDispatcher
that will attempt
to send a Message
to one of its targets.MessageMapper
for FileTarget
, converting payloads of the
File
, byte[]
and String
types to files.MessageStore
that enforces capacity.ScheduleServiceProvider
implementation using an underlying ScheduledExecutorService
.MessageChannel
.Source
using a SourceFactory
.Source
possibly taking into account
the provided message payload instance.MessageHandler
implementation for splitting a single Message
into multiple reply Messages.MessageHandler
adapter for splitter methods.SecurityContext
is not unintentionally clearedSourceFactory
implementation which supports creation of a
StringSource
from either a Document
or String
payloadMessageTargets
.MessageTarget
as a subscriber to this source.
BeanPostProcessor
that creates a method-invoking handler adapter
when it discovers methods annotated with @Subscriber
.@MessageTarget
.MessageCreator
implementation for creating messages with a String payload from a File.ChannelFactory
implementation for creating ThreadLocalChannel
instances.URLName
, where the password has been protected.
mailto
URI.
EndpointInterceptor
implementation that provides transactional
behavior with a PlatformTransactionManager
.MessageSelector
that accepts Messages
that are
not expired.SchedulableTask
could not be scheduled.MessageTarget
from the subscribers of this source.
ChannelInterceptor
that publishes a copy of the intercepted message
to a secondary target while still sending the original message to the main channel.MessageSelector
.
MessageSelector
.
PayloadTransformer
that delegates to an OXM
Marshaller
.PayloadTransformer
that delegates to an OXM
Unmarshaller
.Source
,
Document
, or String
.
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |