|
39 | 39 | import org.springframework.http.server.ServerHttpResponse;
|
40 | 40 | import org.springframework.http.server.ServletServerHttpRequest;
|
41 | 41 | import org.springframework.http.server.ServletServerHttpResponse;
|
| 42 | +import org.springframework.lang.Nullable; |
42 | 43 | import org.springframework.util.Assert;
|
43 | 44 | import org.springframework.util.ClassUtils;
|
44 | 45 | import org.springframework.util.CollectionUtils;
|
@@ -67,15 +68,18 @@ public class JettyRequestUpgradeStrategy implements RequestUpgradeStrategy, Serv
|
67 | 68 | private static final ThreadLocal<WebSocketHandlerContainer> containerHolder =
|
68 | 69 | new NamedThreadLocal<>("WebSocketHandlerContainer");
|
69 | 70 |
|
70 |
| - |
| 71 | + @Nullable |
71 | 72 | private WebSocketPolicy policy;
|
72 | 73 |
|
| 74 | + @Nullable |
73 | 75 | private WebSocketServerFactory factory;
|
74 | 76 |
|
| 77 | + @Nullable |
75 | 78 | private ServletContext servletContext;
|
76 | 79 |
|
77 | 80 | private volatile boolean running = false;
|
78 | 81 |
|
| 82 | + @Nullable |
79 | 83 | private volatile List<WebSocketExtension> supportedExtensions;
|
80 | 84 |
|
81 | 85 |
|
@@ -196,7 +200,7 @@ private Set<String> getExtensionNames() {
|
196 | 200 |
|
197 | 201 | @Override
|
198 | 202 | public void upgrade(ServerHttpRequest request, ServerHttpResponse response,
|
199 |
| - String selectedProtocol, List<WebSocketExtension> selectedExtensions, Principal user, |
| 203 | + @Nullable String selectedProtocol, List<WebSocketExtension> selectedExtensions, @Nullable Principal user, |
200 | 204 | WebSocketHandler wsHandler, Map<String, Object> attributes) throws HandshakeFailureException {
|
201 | 205 |
|
202 | 206 | Assert.isInstanceOf(ServletServerHttpRequest.class, request, "ServletServerHttpRequest required");
|
|
0 commit comments