diff --git a/spring-websocket/src/main/java/org/springframework/web/socket/messaging/DefaultSimpUserRegistry.java b/spring-websocket/src/main/java/org/springframework/web/socket/messaging/DefaultSimpUserRegistry.java index 50c47b63fa..673ede2369 100644 --- a/spring-websocket/src/main/java/org/springframework/web/socket/messaging/DefaultSimpUserRegistry.java +++ b/spring-websocket/src/main/java/org/springframework/web/socket/messaging/DefaultSimpUserRegistry.java @@ -47,6 +47,8 @@ import org.springframework.util.Assert; */ public class DefaultSimpUserRegistry implements SimpUserRegistry, SmartApplicationListener { + private int order = Ordered.LOWEST_PRECEDENCE; + /* Primary lookup that holds all users and their sessions */ private final Map users = new ConcurrentHashMap<>(); @@ -56,9 +58,13 @@ public class DefaultSimpUserRegistry implements SimpUserRegistry, SmartApplicati private final Object sessionLock = new Object(); + public void setOrder(int order) { + this.order = order; + } + @Override public int getOrder() { - return Ordered.LOWEST_PRECEDENCE; + return this.order; }