Package | Description |
---|---|
org.springframework.messaging |
Support for working with messaging APIs and protocols.
|
org.springframework.messaging.core |
Defines interfaces and implementation classes for messaging templates.
|
org.springframework.messaging.simp |
Generic support for Simple Messaging Protocols including protocols such as STOMP.
|
org.springframework.messaging.simp.annotation.support |
Support classes for handling messages from simple messaging protocols
(like STOMP).
|
org.springframework.messaging.simp.broker |
Provides a "simple" message broker implementation along with an abstract base
class and other supporting types such as a registry for subscriptions.
|
org.springframework.messaging.simp.config |
Configuration support for WebSocket messaging using higher level messaging protocols.
|
org.springframework.messaging.simp.stomp |
Generic support for simple messaging protocols (like STOMP).
|
org.springframework.messaging.support |
Provides implementations of
Message along with
a MessageBuilder and MessageHeaderAccessor for building and working with messages and
message headers, as well as various MessageChannel
implementations and channel interceptor support. |
org.springframework.web.socket.messaging |
WebSocket integration for Spring's messaging module.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PollableChannel
A
MessageChannel from which messages may be actively received through polling. |
interface |
SubscribableChannel
A
MessageChannel that maintains a registry of subscribers and invokes
them to handle messages sent through this channel. |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
BeanFactoryMessageChannelDestinationResolver.resolveDestination(String name) |
Modifier and Type | Method and Description |
---|---|
protected Message<?> |
GenericMessagingTemplate.doReceive(MessageChannel channel) |
protected Message<?> |
GenericMessagingTemplate.doReceive(MessageChannel channel,
long timeout) |
protected void |
GenericMessagingTemplate.doSend(MessageChannel channel,
Message<?> message) |
protected void |
GenericMessagingTemplate.doSend(MessageChannel channel,
Message<?> message,
long timeout) |
protected Message<?> |
GenericMessagingTemplate.doSendAndReceive(MessageChannel channel,
Message<?> requestMessage) |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
SimpMessagingTemplate.getMessageChannel()
Return the configured message channel.
|
Constructor and Description |
---|
SimpMessagingTemplate(MessageChannel messageChannel)
Create a new
SimpMessagingTemplate instance. |
Constructor and Description |
---|
SimpAnnotationMethodMessageHandler(SubscribableChannel clientInboundChannel,
MessageChannel clientOutboundChannel,
SimpMessageSendingOperations brokerTemplate)
Create an instance of SimpAnnotationMethodMessageHandler with the given
message channels and broker messaging template.
|
Modifier and Type | Class and Description |
---|---|
class |
OrderedMessageChannelDecorator
Decorator for an
ExecutorSubscribableChannel that ensures messages
are processed in the order they were published to the channel. |
Modifier and Type | Method and Description |
---|---|
MessageChannel |
AbstractBrokerMessageHandler.getClientOutboundChannel() |
protected MessageChannel |
AbstractBrokerMessageHandler.getClientOutboundChannelForSession(String sessionId)
Get the MessageChannel to use for sending messages to clients, possibly
a per-session wrapper when
preservePublishOrder=true . |
Modifier and Type | Method and Description |
---|---|
static void |
OrderedMessageChannelDecorator.configureInterceptor(MessageChannel channel,
boolean preserveOrder)
Install or remove an
ExecutorChannelInterceptor that invokes a
completion task, if found in the headers of the message. |
Constructor and Description |
---|
AbstractBrokerMessageHandler(SubscribableChannel inboundChannel,
MessageChannel outboundChannel,
SubscribableChannel brokerChannel)
Constructor with no destination prefixes (matches all destinations).
|
AbstractBrokerMessageHandler(SubscribableChannel inboundChannel,
MessageChannel outboundChannel,
SubscribableChannel brokerChannel,
Collection<String> destinationPrefixes)
Constructor with destination prefixes to match to destinations of messages.
|
OrderedMessageChannelDecorator(MessageChannel channel,
Log logger) |
SimpleBrokerMessageHandler(SubscribableChannel clientInboundChannel,
MessageChannel clientOutboundChannel,
SubscribableChannel brokerChannel,
Collection<String> destinationPrefixes)
Create a SimpleBrokerMessageHandler instance with the given message channels
and destination prefixes.
|
Modifier and Type | Method and Description |
---|---|
protected MessageChannel |
AbstractBrokerRegistration.getClientOutboundChannel() |
Constructor and Description |
---|
AbstractBrokerRegistration(SubscribableChannel clientInboundChannel,
MessageChannel clientOutboundChannel,
String[] destinationPrefixes) |
MessageBrokerRegistry(SubscribableChannel clientInboundChannel,
MessageChannel clientOutboundChannel) |
SimpleBrokerRegistration(SubscribableChannel inChannel,
MessageChannel outChannel,
String[] prefixes) |
StompBrokerRelayRegistration(SubscribableChannel clientInboundChannel,
MessageChannel clientOutboundChannel,
String[] destinationPrefixes) |
Constructor and Description |
---|
StompBrokerRelayMessageHandler(SubscribableChannel inboundChannel,
MessageChannel outboundChannel,
SubscribableChannel brokerChannel,
Collection<String> destinationPrefixes)
Create a StompBrokerRelayMessageHandler instance with the given message channels
and destination prefixes.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageChannel
Abstract base class for
MessageChannel implementations. |
class |
AbstractSubscribableChannel
Abstract base class for
SubscribableChannel implementations. |
class |
ExecutorSubscribableChannel
A
SubscribableChannel that sends messages to each of its subscribers. |
Modifier and Type | Method and Description |
---|---|
default void |
ExecutorChannelInterceptor.afterMessageHandled(Message<?> message,
MessageChannel channel,
MessageHandler handler,
Exception ex)
Invoked inside the
Runnable submitted to the Executor after calling
the target MessageHandler regardless of the outcome (i.e. |
default void |
ChannelInterceptor.afterReceiveCompletion(Message<?> message,
MessageChannel channel,
Exception ex)
Invoked after the completion of a receive regardless of any exception that
have been raised thus allowing for proper resource cleanup.
|
void |
ChannelInterceptorAdapter.afterReceiveCompletion(Message<?> message,
MessageChannel channel,
Exception ex)
Deprecated.
|
default void |
ChannelInterceptor.afterSendCompletion(Message<?> message,
MessageChannel channel,
boolean sent,
Exception ex)
Invoked after the completion of a send regardless of any exception that
have been raised thus allowing for proper resource cleanup.
|
void |
ChannelInterceptorAdapter.afterSendCompletion(Message<?> message,
MessageChannel channel,
boolean sent,
Exception ex)
Deprecated.
|
Message<?> |
AbstractMessageChannel.ChannelInterceptorChain.applyPostReceive(Message<?> message,
MessageChannel channel) |
void |
AbstractMessageChannel.ChannelInterceptorChain.applyPostSend(Message<?> message,
MessageChannel channel,
boolean sent) |
boolean |
AbstractMessageChannel.ChannelInterceptorChain.applyPreReceive(MessageChannel channel) |
Message<?> |
AbstractMessageChannel.ChannelInterceptorChain.applyPreSend(Message<?> message,
MessageChannel channel) |
default Message<?> |
ExecutorChannelInterceptor.beforeHandle(Message<?> message,
MessageChannel channel,
MessageHandler handler)
Invoked inside the
Runnable submitted to the Executor just before
calling the target MessageHandler to handle the message. |
default Message<?> |
ChannelInterceptor.postReceive(Message<?> message,
MessageChannel channel)
Invoked immediately after a Message has been retrieved but before
it is returned to the caller.
|
Message<?> |
ChannelInterceptorAdapter.postReceive(Message<?> message,
MessageChannel channel)
Deprecated.
|
default void |
ChannelInterceptor.postSend(Message<?> message,
MessageChannel channel,
boolean sent)
Invoked immediately after the send invocation.
|
void |
ChannelInterceptorAdapter.postSend(Message<?> message,
MessageChannel channel,
boolean sent)
Deprecated.
|
default boolean |
ChannelInterceptor.preReceive(MessageChannel channel)
Invoked as soon as receive is called and before a Message is
actually retrieved.
|
boolean |
ChannelInterceptorAdapter.preReceive(MessageChannel channel)
Deprecated.
|
Message<?> |
ImmutableMessageChannelInterceptor.preSend(Message<?> message,
MessageChannel channel) |
default Message<?> |
ChannelInterceptor.preSend(Message<?> message,
MessageChannel channel)
Invoked before the Message is actually sent to the channel.
|
Message<?> |
ChannelInterceptorAdapter.preSend(Message<?> message,
MessageChannel channel)
Deprecated.
|
MessageBuilder<T> |
MessageBuilder.setErrorChannel(MessageChannel errorChannel) |
void |
MessageHeaderAccessor.setErrorChannel(MessageChannel errorChannel) |
MessageBuilder<T> |
MessageBuilder.setReplyChannel(MessageChannel replyChannel) |
void |
MessageHeaderAccessor.setReplyChannel(MessageChannel replyChannel) |
void |
AbstractMessageChannel.ChannelInterceptorChain.triggerAfterReceiveCompletion(Message<?> message,
MessageChannel channel,
Exception ex) |
void |
AbstractMessageChannel.ChannelInterceptorChain.triggerAfterSendCompletion(Message<?> message,
MessageChannel channel,
boolean sent,
Exception ex) |
Modifier and Type | Method and Description |
---|---|
void |
StompSubProtocolHandler.afterSessionEnded(WebSocketSession session,
CloseStatus closeStatus,
MessageChannel outputChannel) |
void |
SubProtocolHandler.afterSessionEnded(WebSocketSession session,
CloseStatus closeStatus,
MessageChannel outputChannel)
Invoked after a
WebSocketSession has ended. |
void |
StompSubProtocolHandler.afterSessionStarted(WebSocketSession session,
MessageChannel outputChannel) |
void |
SubProtocolHandler.afterSessionStarted(WebSocketSession session,
MessageChannel outputChannel)
Invoked after a
WebSocketSession has started. |
void |
StompSubProtocolHandler.handleMessageFromClient(WebSocketSession session,
WebSocketMessage<?> webSocketMessage,
MessageChannel outputChannel)
Handle incoming WebSocket messages from clients.
|
void |
SubProtocolHandler.handleMessageFromClient(WebSocketSession session,
WebSocketMessage<?> message,
MessageChannel outputChannel)
Handle the given
WebSocketMessage received from a client. |
Constructor and Description |
---|
SubProtocolWebSocketHandler(MessageChannel clientInboundChannel,
SubscribableChannel clientOutboundChannel)
Create a new
SubProtocolWebSocketHandler for the given inbound and outbound channels. |
WebSocketAnnotationMethodMessageHandler(SubscribableChannel clientInChannel,
MessageChannel clientOutChannel,
SimpMessageSendingOperations brokerTemplate) |