|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
MessageChannel implementations providing common
properties such as the channel name and DispatcherPolicy.MessageHandler interface that creates an
invoker for the specified method and target object.MessageHandler
adapter for the provided object and method.IdGenerator as well as a setter
for providing a custom id generator implementation.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.BlockingQueue.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.MessageChannel.Messages from one or more
MessageChannels.ChannelRegistry.Messages from this channel.
ConcurrencyPolicy settings for a @MessageEndpoint.MessageHandler implementation that encapsulates a
ThreadPoolTaskExecutor and delegates to a wrapped handler for
concurrent, asynchronous message handling.ChannelRegistry.EndpointRegistry.MessageBus.MessageDispatcher.MessageDistributor interface.MessageEndpoint interface.MessageHandler that invokes the specified method
on the provided target object.DefaultMessageHandlerAdapter for the provided object and method.MessageMapper
and then passes the resulting object to the provided Target.MessageDispatcher.Throwable.Throwable payload.Message to an object.
null to
indicate 'never expire'.
Message if available, may be null.
DispatcherPolicy.rejectionLimit is reached.
Message if available, may be null.
Messages based upon a condition that is met when a
Message arrives.Message to one or more
MessageHandlers.BeanPostProcessor implementation that generates endpoints for
classes annotated with @MessageEndpoint.MessageHandlers.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.MessageSelector.Comparator implementation based on the 'sequenceNumber'
property of a Message's header.MessagingTaskScheduler.MessagingTask schedulers.MessagingTaskScheduler.MessageChannels.MessageChannel based on the
Message's payload type.MessageSelector implementation that checks the type of the
Message payload.PollableSource,
delegates to a MessageMapper to create messages from those objects,
and then sends the resulting messages to the provided MessageChannel.PriorityChannel.MessagePriorityComparator.BeanPostProcessor that adds a message publishing interceptor when
it discovers annotated methods.Messages that are not accepted by the provided selector.
MultiChannelRouter that routes to a statically
configured list of recipients.ReplyHandler.
ReplyHandler.
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.@Router.MessageHandler adapter for router methods.MessageDispatcher strategy for handlers that may
be scheduled.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.null to
indicate 'never expire'.
MessageMapper to use when creating a message from the
return value Object.
ScheduledExecutorService to use for scheduling message dispatchers.
DispatcherPolicy.rejectionLimit is reached.
MessageStore that enforces capacity.MessagingTaskScheduler that understands
PollingSchedules.MethodInvoker.MessageMapper implementation that simply wraps and unwraps a
payload object in a Message.MessageChannel.@Splitter.MessageHandler adapter for splitter methods.BeanPostProcessor that creates a method-invoking handler adapter
when it discovers methods annotated with @Subscriber.handler(s) in a
sender's thread (returning after at most one handles the message).Message from the given object.
Message with the given object as its payload.
MessageSelector that accepts Messages that are
not expired.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 | ||||||||