Package org.springframework.messaging.simp.annotation.support

Class SimpAnnotationMethodMessageHandler

java.lang.Object

org.springframework.messaging.handler.invocation.AbstractMethodMessageHandler<SimpMessageMappingInfo>

org.springframework.messaging.simp.annotation.support.SimpAnnotationMethodMessageHandler

All Implemented Interfaces:

Aware, InitializingBean, ApplicationContextAware, EmbeddedValueResolverAware, Lifecycle, Phased, SmartLifecycle, MessageHandler

Direct Known Subclasses:

WebSocketAnnotationMethodMessageHandler

public class SimpAnnotationMethodMessageHandler
extends AbstractMethodMessageHandler<SimpMessageMappingInfo>
implements EmbeddedValueResolverAware, SmartLifecycle

A handler for messages delegating to @MessageMapping and @SubscribeMapping annotated methods.

Supports Ant-style path patterns with template variables.

Since:

4.0

Author:

Rossen Stoyanchev, Brian Clozel, Juergen Hoeller

Field Summary

Fields inherited from class org.springframework.messaging.handler.invocation.AbstractMethodMessageHandler

logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
SimpAnnotationMethodMessageHandler(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, SimpMessageSendingOperations brokerTemplate)	Create an instance of SimpAnnotationMethodMessageHandler with the given message channels and broker messaging template.

Method Summary

Modifier and Type	Method	Description
protected AbstractExceptionHandlerMethodResolver	createExceptionHandlerMethodResolverFor(Class<?> beanType)
ConversionService	getConversionService()	Return the configured ConversionService.
protected String	getDestination(Message<?> message)
protected Set<String>	getDirectLookupDestinations(SimpMessageMappingInfo mapping)	Return destinations contained in the mapping that are not patterns and are therefore suitable for direct lookups.
protected Log	getHandlerMethodLogger()	Return a logger to set on InvocableHandlerMethod.
MessageHeaderInitializer	getHeaderInitializer()	Return the configured header initializer.
protected String	getLookupDestination(String destination)	Check whether the given destination (of an incoming message) matches to one of the configured destination prefixes and if so return the remaining portion of the destination after the matched prefix.
protected Comparator<SimpMessageMappingInfo>	getMappingComparator(Message<?> message)	Return a comparator for sorting matching mappings.
protected SimpMessageMappingInfo	getMappingForMethod(Method method, Class<?> handlerType)	Provide the mapping for a handler method.
protected SimpMessageMappingInfo	getMatchingMapping(SimpMessageMappingInfo mapping, Message<?> message)	Check if a mapping matches the current message and return a possibly new mapping with conditions relevant to the current request.
MessageConverter	getMessageConverter()	Return the configured MessageConverter.
PathMatcher	getPathMatcher()	Return the PathMatcher implementation to use for matching destinations.
int	getPhase()	Return the phase that this lifecycle object is supposed to run in.
protected Log	getReturnValueHandlerLogger()	Return a logger to set on HandlerMethodReturnValueHandlerComposite.
Validator	getValidator()	Return the configured Validator instance.
protected void	handleMatch(SimpMessageMappingInfo mapping, HandlerMethod handlerMethod, String lookupDestination, Message<?> message)
protected List<HandlerMethodArgumentResolver>	initArgumentResolvers()	Return the list of argument resolvers to use.
protected List<? extends HandlerMethodReturnValueHandler>	initReturnValueHandlers()	Return the list of return value handlers to use.
protected boolean	isHandler(Class<?> beanType)	Whether the given bean type should be introspected for messaging handling methods.
final boolean	isRunning()	Check whether this component is currently running.
protected String[]	resolveEmbeddedValuesInDestinations(String[] destinations)	Resolve placeholder values in the given array of destinations.
void	setConversionService(ConversionService conversionService)	Configure a ConversionService to use when resolving method arguments, for example message header values.
void	setDestinationPrefixes(Collection<String> prefixes)	When this property is configured only messages to destinations matching one of the configured prefixes are eligible for handling.
void	setEmbeddedValueResolver(StringValueResolver resolver)	Set the StringValueResolver to use for resolving embedded definition values.
void	setHeaderInitializer(MessageHeaderInitializer headerInitializer)	Configure a MessageHeaderInitializer to pass on to HandlerMethodReturnValueHandlers that send messages from controller return values.
void	setMessageConverter(MessageConverter converter)	Configure a MessageConverter to use to convert the payload of a message from its serialized form with a specific MIME type to an Object matching the target method parameter.
void	setPathMatcher(PathMatcher pathMatcher)	Set the PathMatcher implementation to use for matching destinations against configured destination patterns.
void	setPhase(int phase)	Set the phase that this handler should run in.
void	setValidator(Validator validator)	Set the Validator instance used for validating @Payload arguments.
final void	start()	Start this component.
final void	stop()	Stop this component, typically in a synchronous fashion, such that the component is fully stopped upon return of this method.
final void	stop(Runnable callback)	Indicates that a Lifecycle component must stop if it is currently running.

Methods inherited from class org.springframework.messaging.handler.invocation.AbstractMethodMessageHandler

afterPropertiesSet, createHandlerMethod, detectHandlerMethods, getApplicationContext, getArgumentResolvers, getCustomArgumentResolvers, getCustomReturnValueHandlers, getDestinationPrefixes, getExceptionHandlerMethod, getHandlerMethods, getReturnValueHandlers, handleMessage, handleMessageInternal, handleNoMatch, processHandlerMethodException, registerExceptionHandlerAdvice, registerHandlerMethod, setApplicationContext, setArgumentResolvers, setCustomArgumentResolvers, setCustomReturnValueHandlers, setReturnValueHandlers, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.context.SmartLifecycle

isAutoStartup

Constructor Details

SimpAnnotationMethodMessageHandler

public SimpAnnotationMethodMessageHandler(SubscribableChannel clientInboundChannel,
 MessageChannel clientOutboundChannel,
 SimpMessageSendingOperations brokerTemplate)

Create an instance of SimpAnnotationMethodMessageHandler with the given message channels and broker messaging template.

Parameters:

clientInboundChannel - the channel for receiving messages from clients (for example, WebSocket clients)

clientOutboundChannel - the channel for messages to clients (for example, WebSocket clients)

brokerTemplate - a messaging template to send application messages to the broker

Method Details

setDestinationPrefixes

public void setDestinationPrefixes(@Nullable
 Collection<String> prefixes)

When this property is configured only messages to destinations matching one of the configured prefixes are eligible for handling. When there is a match the prefix is removed and only the remaining part of the destination is used for method-mapping purposes.

By default, no prefixes are configured in which case all messages are eligible for handling.

Destination prefixes are expected to be slash-separated Strings and therefore a slash is automatically appended where missing to ensure a proper prefix-based match (i.e. matching complete segments).

Note however that the remaining portion of a destination after the prefix may use a different separator (for example, commonly "." in messaging) depending on the configured PathMatcher.

Overrides:

setDestinationPrefixes in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

setMessageConverter

public void setMessageConverter(MessageConverter converter)

Configure a MessageConverter to use to convert the payload of a message from its serialized form with a specific MIME type to an Object matching the target method parameter. The converter is also used when sending a message to the message broker.

See Also:

• CompositeMessageConverter

getMessageConverter

public MessageConverter getMessageConverter()

Return the configured MessageConverter.

setConversionService

public void setConversionService(ConversionService conversionService)

Configure a ConversionService to use when resolving method arguments, for example message header values.

By default, DefaultFormattingConversionService is used.

getConversionService

public ConversionService getConversionService()

Return the configured ConversionService.

setPathMatcher

public void setPathMatcher(PathMatcher pathMatcher)

Set the PathMatcher implementation to use for matching destinations against configured destination patterns.

By default, AntPathMatcher is used.

getPathMatcher

public PathMatcher getPathMatcher()

Return the PathMatcher implementation to use for matching destinations.

getValidator

@Nullable
public Validator getValidator()

Return the configured Validator instance.

setValidator

public void setValidator(@Nullable
 Validator validator)

Set the Validator instance used for validating @Payload arguments.

See Also:

• Validated
• PayloadMethodArgumentResolver

setEmbeddedValueResolver

public void setEmbeddedValueResolver(StringValueResolver resolver)

Description copied from interface: EmbeddedValueResolverAware

Set the StringValueResolver to use for resolving embedded definition values.

Specified by:

setEmbeddedValueResolver in interface EmbeddedValueResolverAware

setHeaderInitializer

public void setHeaderInitializer(@Nullable
 MessageHeaderInitializer headerInitializer)

Configure a MessageHeaderInitializer to pass on to HandlerMethodReturnValueHandlers that send messages from controller return values.

By default, this property is not set.

getHeaderInitializer

@Nullable
public MessageHeaderInitializer getHeaderInitializer()

Return the configured header initializer.

setPhase

public void setPhase(int phase)

Set the phase that this handler should run in.

By default, this is SmartLifecycle.DEFAULT_PHASE, but with @EnableWebSocketMessageBroker configuration it is set to 0.

Since:

6.1.4

getPhase

public int getPhase()

Description copied from interface: SmartLifecycle

Return the phase that this lifecycle object is supposed to run in.

The default implementation returns SmartLifecycle.DEFAULT_PHASE in order to let stop() callbacks execute before regular Lifecycle implementations.

Specified by:

getPhase in interface Phased

Specified by:

getPhase in interface SmartLifecycle

See Also:

• SmartLifecycle.isAutoStartup()
• Lifecycle.start()
• SmartLifecycle.stop(Runnable)
• DefaultLifecycleProcessor.getPhase(Lifecycle)

start

public final void start()

Description copied from interface: Lifecycle

Start this component.

Should not throw an exception if the component is already running.

In the case of a container, this will propagate the start signal to all components that apply.

Specified by:

start in interface Lifecycle

See Also:

• SmartLifecycle.isAutoStartup()

stop

public final void stop()

Description copied from interface: Lifecycle

Stop this component, typically in a synchronous fashion, such that the component is fully stopped upon return of this method. Consider implementing SmartLifecycle and its stop(Runnable) variant when asynchronous stop behavior is necessary.

Note that this stop notification is not guaranteed to come before destruction: On regular shutdown, Lifecycle beans will first receive a stop notification before the general destruction callbacks are being propagated; however, on hot refresh during a context's lifetime or on aborted refresh attempts, a given bean's destroy method will be called without any consideration of stop signals upfront.

Should not throw an exception if the component is not running (not started yet).

In the case of a container, this will propagate the stop signal to all components that apply.

Specified by:

stop in interface Lifecycle

See Also:

• SmartLifecycle.stop(Runnable)
• DisposableBean.destroy()

stop

public final void stop(Runnable callback)

Description copied from interface: SmartLifecycle

Indicates that a Lifecycle component must stop if it is currently running.

The provided callback is used by the LifecycleProcessor to support an ordered, and potentially concurrent, shutdown of all components having a common shutdown order value. The callback must be executed after the SmartLifecycle component does indeed stop.

The LifecycleProcessor will call only this variant of the stop method; i.e. Lifecycle.stop() will not be called for SmartLifecycle implementations unless explicitly delegated to within the implementation of this method.

The default implementation delegates to Lifecycle.stop() and immediately triggers the given callback in the calling thread. Note that there is no synchronization between the two, so custom implementations may at least want to put the same steps within their common lifecycle monitor (if any).

Specified by:

stop in interface SmartLifecycle

See Also:

• Lifecycle.stop()
• SmartLifecycle.getPhase()

isRunning

public final boolean isRunning()

Description copied from interface: Lifecycle

Check whether this component is currently running.

In the case of a container, this will return true only if all components that apply are currently running.

Specified by:

isRunning in interface Lifecycle

Returns:

whether the component is currently running

initArgumentResolvers

protected List<HandlerMethodArgumentResolver> initArgumentResolvers()

Description copied from class: AbstractMethodMessageHandler

Return the list of argument resolvers to use. Invoked only if the resolvers have not already been set via AbstractMethodMessageHandler.setArgumentResolvers(java.util.List<org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver>).

Subclasses should also take into account custom argument types configured via AbstractMethodMessageHandler.setCustomArgumentResolvers(java.util.List<org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver>).

Specified by:

initArgumentResolvers in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

initReturnValueHandlers

protected List<? extends HandlerMethodReturnValueHandler> initReturnValueHandlers()

Description copied from class: AbstractMethodMessageHandler

Return the list of return value handlers to use. Invoked only if the return value handlers have not already been set via AbstractMethodMessageHandler.setReturnValueHandlers(java.util.List<org.springframework.messaging.handler.invocation.HandlerMethodReturnValueHandler>).

Subclasses should also take into account custom return value types configured via AbstractMethodMessageHandler.setCustomReturnValueHandlers(java.util.List<org.springframework.messaging.handler.invocation.HandlerMethodReturnValueHandler>).

Specified by:

initReturnValueHandlers in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

getReturnValueHandlerLogger

protected Log getReturnValueHandlerLogger()

Description copied from class: AbstractMethodMessageHandler

Return a logger to set on HandlerMethodReturnValueHandlerComposite.

Overrides:

getReturnValueHandlerLogger in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

getHandlerMethodLogger

protected Log getHandlerMethodLogger()

Description copied from class: AbstractMethodMessageHandler

Return a logger to set on InvocableHandlerMethod.

Overrides:

getHandlerMethodLogger in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

isHandler

protected boolean isHandler(Class<?> beanType)

Description copied from class: AbstractMethodMessageHandler

Whether the given bean type should be introspected for messaging handling methods.

Specified by:

isHandler in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

getMappingForMethod

@Nullable
protected SimpMessageMappingInfo getMappingForMethod(Method method,
 Class<?> handlerType)

Description copied from class: AbstractMethodMessageHandler

Provide the mapping for a handler method.

Specified by:

getMappingForMethod in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

Parameters:

method - the method to provide a mapping for

handlerType - the handler type, possibly a subtype of the method's declaring class

Returns:

the mapping, or null if the method is not mapped

resolveEmbeddedValuesInDestinations

protected String[] resolveEmbeddedValuesInDestinations(String[] destinations)

Resolve placeholder values in the given array of destinations.

Returns:

a new array with updated destinations

Since:

4.2

getDirectLookupDestinations

protected Set<String> getDirectLookupDestinations(SimpMessageMappingInfo mapping)

Description copied from class: AbstractMethodMessageHandler

Return destinations contained in the mapping that are not patterns and are therefore suitable for direct lookups.

Specified by:

getDirectLookupDestinations in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

getDestination

@Nullable
protected String getDestination(Message<?> message)

Specified by:

getDestination in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

getLookupDestination

@Nullable
protected String getLookupDestination(@Nullable
 String destination)

Description copied from class: AbstractMethodMessageHandler

Check whether the given destination (of an incoming message) matches to one of the configured destination prefixes and if so return the remaining portion of the destination after the matched prefix.

If there are no matching prefixes, return null.

If there are no destination prefixes, return the destination as is.

Overrides:

getLookupDestination in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

getMatchingMapping

@Nullable
protected SimpMessageMappingInfo getMatchingMapping(SimpMessageMappingInfo mapping,
 Message<?> message)

Description copied from class: AbstractMethodMessageHandler

Check if a mapping matches the current message and return a possibly new mapping with conditions relevant to the current request.

Specified by:

getMatchingMapping in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

Parameters:

mapping - the mapping to get a match for

message - the message being handled

Returns:

the match or null if there is no match

getMappingComparator

protected Comparator<SimpMessageMappingInfo> getMappingComparator(Message<?> message)

Description copied from class: AbstractMethodMessageHandler

Return a comparator for sorting matching mappings. The returned comparator should sort 'better' matches higher.

Specified by:

getMappingComparator in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

Parameters:

message - the current Message

Returns:

the comparator, never null

handleMatch

protected void handleMatch(SimpMessageMappingInfo mapping,
 HandlerMethod handlerMethod,
 String lookupDestination,
 Message<?> message)

Overrides:

handleMatch in class AbstractMethodMessageHandler<SimpMessageMappingInfo>

createExceptionHandlerMethodResolverFor

protected AbstractExceptionHandlerMethodResolver createExceptionHandlerMethodResolverFor(Class<?> beanType)

Specified by:

createExceptionHandlerMethodResolverFor in class AbstractMethodMessageHandler<SimpMessageMappingInfo>