Class DefaultUserDestinationResolver
- java.lang.Object
- org.springframework.messaging.simp.user.DefaultUserDestinationResolver
- All Implemented Interfaces:
UserDestinationResolver
public class DefaultUserDestinationResolver extends Object implements UserDestinationResolver
A default implementation ofUserDestinationResolverthat relies on aSimpUserRegistryto find active sessions for a user.When a user attempts to subscribe, e.g. to "/user/queue/position-updates", the "/user" prefix is removed and a unique suffix added based on the session id, e.g. "/queue/position-updates-useri9oqdfzo" to ensure different users can subscribe to the same logical destination without colliding.
When sending to a user, e.g. "/user/{username}/queue/position-updates", the "/user/{username}" prefix is removed and a suffix based on active session id's is added, e.g. "/queue/position-updates-useri9oqdfzo".
- Since:
- 4.0
- Author:
- Rossen Stoyanchev, Brian Clozel
Constructor Summary
Constructors Constructor Description DefaultUserDestinationResolver(SimpUserRegistry userRegistry)Create an instance that will access user session id information through the provided registry.
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected booleancheckDestination(String destination, String requiredPrefix)StringgetDestinationPrefix()Return the configured prefix for user destinations.SimpUserRegistrygetSimpUserRegistry()Return the configuredSimpUserRegistry.protected StringgetTargetDestination(String sourceDestination, String actualDestination, String sessionId, String user)This method determines how to translate the source "user" destination to an actual target destination for the given active user session.booleanisRemoveLeadingSlash()Whether to remove the leading slash from target destinations.UserDestinationResultresolveDestination(Message<?> message)Resolve the given message with a user destination to one or more messages with actual destinations, one for each active user session.voidsetPathMatcher(PathMatcher pathMatcher)Deprecated.as of 4.3.14 this property is no longer used and is replaced bysetRemoveLeadingSlash(boolean)that indicates more explicitly whether to keep the leading slash which may or may not be the case regardless of how thePathMatcheris configured.voidsetRemoveLeadingSlash(boolean remove)Use this property to indicate whether the leading slash from translated user destinations should be removed or not.voidsetUserDestinationPrefix(String prefix)The prefix used to identify user destinations.StringtoString()
Constructor Detail
DefaultUserDestinationResolver
public DefaultUserDestinationResolver(SimpUserRegistry userRegistry)
Create an instance that will access user session id information through the provided registry.- Parameters:
userRegistry- the registry, nevernull
Method Detail
getSimpUserRegistry
public SimpUserRegistry getSimpUserRegistry()
Return the configuredSimpUserRegistry.
setUserDestinationPrefix
public void setUserDestinationPrefix(String prefix)
The prefix used to identify user destinations. Any destinations that do not start with the given prefix are not be resolved.The default prefix is "/user/".
- Parameters:
prefix- the prefix to use
getDestinationPrefix
public String getDestinationPrefix()
Return the configured prefix for user destinations.
setRemoveLeadingSlash
public void setRemoveLeadingSlash(boolean remove)
Use this property to indicate whether the leading slash from translated user destinations should be removed or not. This depends on the destination prefixes the message broker is configured with.By default this is set to
false, i.e. "do not change the target destination", althoughAbstractMessageBrokerConfigurationmay change that totrueif the configured destinations do not have a leading slash.- Parameters:
remove- whether to remove the leading slash- Since:
- 4.3.14
isRemoveLeadingSlash
public boolean isRemoveLeadingSlash()
Whether to remove the leading slash from target destinations.- Since:
- 4.3.14
setPathMatcher
@Deprecated public void setPathMatcher(PathMatcher pathMatcher)
Deprecated.as of 4.3.14 this property is no longer used and is replaced bysetRemoveLeadingSlash(boolean)that indicates more explicitly whether to keep the leading slash which may or may not be the case regardless of how thePathMatcheris configured.Provide thePathMatcherin use for working with destinations which in turn helps to determine whether the leading slash should be kept in actual destinations after removing theuserDestinationPrefix.By default actual destinations have a leading slash, e.g.
/queue/position-updateswhich makes sense with brokers that support destinations with slash as separator. When aPathMatcheris provided that supports an alternative separator, then resulting destinations won't have a leading slash, e.g.jms.queue.position-updates.- Parameters:
pathMatcher- the PathMatcher used to work with destinations- Since:
- 4.3
resolveDestination
public UserDestinationResult resolveDestination(Message<?> message)
Description copied from interface:UserDestinationResolverResolve the given message with a user destination to one or more messages with actual destinations, one for each active user session.- Specified by:
resolveDestinationin interfaceUserDestinationResolver- Parameters:
message- the message to try to resolve- Returns:
- 0 or more target messages (one for each active session), or
nullif the source message does not contain a user destination.
checkDestination
protected boolean checkDestination(String destination, String requiredPrefix)
getTargetDestination
protected String getTargetDestination(String sourceDestination, String actualDestination, String sessionId, String user)
This method determines how to translate the source "user" destination to an actual target destination for the given active user session.- Parameters:
sourceDestination- the source destination from the input message.actualDestination- a subset of the destination without any user prefix.sessionId- the id of an active user session, nevernull.user- the target user, possiblynull, e.g if not authenticated.- Returns:
- a target destination, or
nullif none