|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
ChannelFactory
implementations.MessageEndpoint
implementations.JmsTemplate
.MailHeaderGenerators
.MessageChannel
implementations providing common
properties such as the channel name and DispatcherPolicy
.MessageHandler
interface that invokes the specified method and target object.MessageHandler
adapter for the provided object and method.MessagingTaskScheduler
implementations.MessageHandler
implementation that waits for a complete
group of Messages
to arrive and then delegates to an
Aggregator
to combine them into a single Message
.CompletionStrategy
.
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.MessageMapper
implementation for annotated handler methods.ApplicationEvents
within messages.MessagingEvents
.PollableSource
and provides a timeout-aware receive method.Target
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.MessageListener
implementation that converts the received JMS
message into a Spring Integration message and then sends that to a channel.Messages
from one or more
MessageChannels
.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
.Target
implementation that encapsulates an Executor and delegates
to a wrapped target for concurrent, asynchronous message handling.ChannelRegistry
.EndpointRegistry
.MessageBus
.HeaderMapper
implementation for JMS Messages
.MailHeaderGenerator
.MessageCreator
that uses the provide value
as the Message's
payload.MessageHandler
that invokes the specified method and target object.DefaultMessageHandlerAdapter
for the provided object and method.MessageMapper
that returns the
Message's
payload.MethodInvoker
to be used when the actual Method
reference is known.SimpleDispatcher
that adds message retrieval
capabilities by polling a PollableSource
for Messages
.handler(s)
in a
sender's thread (returning after at most one handles the message).ChannelFactory
for creating DirectChannel
instances.MessageDispatcher
.Throwable
.Throwable
payload.MessageCreator
that creates Message
instances with the
absolute path to the File
as payload.null
to
indicate 'never expire'.
DispatcherPolicy.rejectionLimit
is reached.
MessageEndpoint
interface for invoking
MessageHandlers
.MessageConverter
implementation that delegates to an existing
converter as well as an implementation of MessageHeaderMapper
.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
from an Object.BeanPostProcessor
implementation that generates endpoints for
classes annotated with @MessageEndpoint
.MessageHandlers
.MessageHandler
interface.MessageHeader
.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 'sequenceNumber
'
property of a Message's
header.ApplicationEvent
that wraps a Message
.Messages
and MessagingEvents
.RequestReplyTemplate
and exposing setter methods for
configuring request and reply MessageChannels
.MessagingTaskScheduler
.MessagingTask
schedulers.MessageChannels
.MethodInvoker
to be used when only the method name is known.Schedule
.
MessageChannel
based on the
Message's
payload type.MessageSelector
implementation that checks the type of the
Message
payload.@MessageEndpoint
annotation in order to provide the
scheduling information for that endpoint.MessagingTask
that combines polling and dispatching.PriorityChannel.MessagePriorityComparator
.ChannelFactory
for creating PriorityChannel
instances.BeanPostProcessor
that adds a message publishing interceptor when
it discovers annotated methods.Messages
that are not accepted by the provided selector.
ChannelFactory
, which will create instances of a
QueueChannel
.null
if no message is available.
MultiChannelRouter
that routes to a statically
configured list of recipients.QueueChannel
that delegates to a
SynchronousQueue
internally.ChannelFactory
for creating RendezvousChannel
instances.MessageChannels
.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.MessageSelectors
, check
whether they accept the current message.
CompletionStrategy
that simply compares the
current size of the message list to the expected 'sequenceSize' according to
the first Message
in the list.ChannelFactory
to use for auto-creating channels.
null
to
indicate 'never expire'.
MessageCreator
to use when creating a message from the
return value Object.
ScheduledExecutorService
to use for scheduling message dispatchers.
DispatcherPolicy.rejectionLimit
is reached.
MessageDispatcher
.MessageMapper
for FileTarget
, converting payloads of the
File
, byte[]
and String
types to files.MessageStore
that enforces capacity.MessagingTaskScheduler
that understands
PollingSchedules
.MessageChannel
.Messages
.Source
and then sends the resulting messages to the provided MessageChannel
.@Splitter
.MessageHandler
adapter for splitter methods.Target
as a subscriber to this source.
BeanPostProcessor
that creates a method-invoking handler adapter
when it discovers methods annotated with @Subscriber
.Targets
to a MessageChannel
including the creation, scheduling, and lifecycle management of dispatchers.Messages
can be sent.MessageEndpoint
implementations to which Messages may be sent.MessageCreator
implementation for creating messages with a String payload from a File.ChannelFactory
implementation for creating ThreadLocalChannel
instances.MessageSelector
that accepts Messages
that are
not expired.Target
from the subscribers of this source.
ChannelInterceptor
that publishes a copy of the intercepted message
to a secondary channel while still sending the original message to the main channel.MessageSelectors
.
MessageSelectors
.
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |