Uses of Interface
org.springframework.messaging.MessageChannel
Packages that use MessageChannel
Package
Description
Support for working with messaging APIs and protocols.
Defines interfaces and implementation classes for messaging templates.
Generic support for Simple Messaging Protocols including protocols such as STOMP.
Support classes for handling messages from simple messaging protocols
(like STOMP).
Provides a "simple" message broker implementation along with an abstract base
class and other supporting types such as a registry for subscriptions.
Configuration support for WebSocket messaging using higher level messaging protocols.
Generic support for simple messaging protocols (like STOMP).
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.WebSocket integration for Spring's messaging module.
-
Uses of MessageChannel in org.springframework.messaging
Subinterfaces of MessageChannel in org.springframework.messagingModifier and TypeInterfaceDescriptioninterface
AMessageChannel
from which messages may be actively received through polling.interface
AMessageChannel
that maintains a registry of subscribers and invokes them to handle messages sent through this channel. -
Uses of MessageChannel in org.springframework.messaging.core
Methods in org.springframework.messaging.core that return MessageChannelModifier and TypeMethodDescriptionBeanFactoryMessageChannelDestinationResolver.resolveDestination
(String name) Methods in org.springframework.messaging.core with parameters of type MessageChannelModifier and TypeMethodDescriptionprotected final Message<?>
GenericMessagingTemplate.doReceive
(MessageChannel channel) protected final Message<?>
GenericMessagingTemplate.doReceive
(MessageChannel channel, long timeout) protected final void
GenericMessagingTemplate.doSend
(MessageChannel channel, Message<?> message) protected final void
GenericMessagingTemplate.doSend
(MessageChannel channel, Message<?> message, long timeout) protected final Message<?>
GenericMessagingTemplate.doSendAndReceive
(MessageChannel channel, Message<?> requestMessage) -
Uses of MessageChannel in org.springframework.messaging.simp
Methods in org.springframework.messaging.simp that return MessageChannelModifier and TypeMethodDescriptionSimpMessagingTemplate.getMessageChannel()
Return the configured message channel.Constructors in org.springframework.messaging.simp with parameters of type MessageChannelModifierConstructorDescriptionSimpMessagingTemplate
(MessageChannel messageChannel) Create a newSimpMessagingTemplate
instance. -
Uses of MessageChannel in org.springframework.messaging.simp.annotation.support
Constructors in org.springframework.messaging.simp.annotation.support with parameters of type MessageChannelModifierConstructorDescriptionSimpAnnotationMethodMessageHandler
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, SimpMessageSendingOperations brokerTemplate) Create an instance of SimpAnnotationMethodMessageHandler with the given message channels and broker messaging template. -
Uses of MessageChannel in org.springframework.messaging.simp.broker
Classes in org.springframework.messaging.simp.broker that implement MessageChannelModifier and TypeClassDescriptionclass
Decorator for anExecutorSubscribableChannel
that ensures messages are processed in the order they were published to the channel.Methods in org.springframework.messaging.simp.broker that return MessageChannelModifier and TypeMethodDescriptionAbstractBrokerMessageHandler.getClientOutboundChannel()
protected MessageChannel
AbstractBrokerMessageHandler.getClientOutboundChannelForSession
(String sessionId) Get the MessageChannel to use for sending messages to clients, possibly a per-session wrapper whenpreservePublishOrder=true
.Methods in org.springframework.messaging.simp.broker with parameters of type MessageChannelModifier and TypeMethodDescriptionstatic void
OrderedMessageChannelDecorator.configureInterceptor
(MessageChannel channel, boolean preserveOrder) Install or remove anExecutorChannelInterceptor
that invokes a completion task, if found in the headers of the message.Constructors in org.springframework.messaging.simp.broker with parameters of type MessageChannelModifierConstructorDescriptionAbstractBrokerMessageHandler
(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. -
Uses of MessageChannel in org.springframework.messaging.simp.config
Methods in org.springframework.messaging.simp.config that return MessageChannelModifier and TypeMethodDescriptionprotected MessageChannel
AbstractBrokerRegistration.getClientOutboundChannel()
Constructors in org.springframework.messaging.simp.config with parameters of type MessageChannelModifierConstructorDescriptionAbstractBrokerRegistration
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, String[] destinationPrefixes) Create a new broker registration.MessageBrokerRegistry
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel) SimpleBrokerRegistration
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, String[] destinationPrefixes) Create a newSimpleBrokerRegistration
.StompBrokerRelayRegistration
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, String[] destinationPrefixes) Create a newStompBrokerRelayRegistration
. -
Uses of MessageChannel in org.springframework.messaging.simp.stomp
Constructors in org.springframework.messaging.simp.stomp with parameters of type MessageChannelModifierConstructorDescriptionStompBrokerRelayMessageHandler
(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel, Collection<String> destinationPrefixes) Create a StompBrokerRelayMessageHandler instance with the given message channels and destination prefixes. -
Uses of MessageChannel in org.springframework.messaging.support
Classes in org.springframework.messaging.support that implement MessageChannelModifier and TypeClassDescriptionclass
Abstract base class forMessageChannel
implementations.class
Abstract base class forSubscribableChannel
implementations.class
ASubscribableChannel
that sends messages to each of its subscribers.Methods in org.springframework.messaging.support with parameters of type MessageChannelModifier and TypeMethodDescriptiondefault void
ExecutorChannelInterceptor.afterMessageHandled
(Message<?> message, MessageChannel channel, MessageHandler handler, Exception ex) Invoked inside theRunnable
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.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.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 theRunnable
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.default void
ChannelInterceptor.postSend
(Message<?> message, MessageChannel channel, boolean sent) Invoked immediately after the send invocation.default boolean
ChannelInterceptor.preReceive
(MessageChannel channel) Invoked as soon as receive is called and before a Message is actually retrieved.default Message<?>
ChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) Invoked before the Message is actually sent to the channel.Message<?>
ImmutableMessageChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) MessageBuilder.setErrorChannel
(MessageChannel errorChannel) void
MessageHeaderAccessor.setErrorChannel
(MessageChannel errorChannel) 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) -
Uses of MessageChannel in org.springframework.web.socket.messaging
Methods in org.springframework.web.socket.messaging with parameters of type MessageChannelModifier and TypeMethodDescriptionvoid
StompSubProtocolHandler.afterSessionEnded
(WebSocketSession session, CloseStatus closeStatus, MessageChannel outputChannel) void
SubProtocolHandler.afterSessionEnded
(WebSocketSession session, CloseStatus closeStatus, MessageChannel outputChannel) Invoked after aWebSocketSession
has ended.void
StompSubProtocolHandler.afterSessionStarted
(WebSocketSession session, MessageChannel outputChannel) void
SubProtocolHandler.afterSessionStarted
(WebSocketSession session, MessageChannel outputChannel) Invoked after aWebSocketSession
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 givenWebSocketMessage
received from a client.Constructors in org.springframework.web.socket.messaging with parameters of type MessageChannelModifierConstructorDescriptionSubProtocolWebSocketHandler
(MessageChannel clientInboundChannel, SubscribableChannel clientOutboundChannel) Create a newSubProtocolWebSocketHandler
for the given inbound and outbound channels.WebSocketAnnotationMethodMessageHandler
(SubscribableChannel clientInChannel, MessageChannel clientOutChannel, SimpMessageSendingOperations brokerTemplate)