24
24
import org .junit .runner .RunWith ;
25
25
import org .junit .runners .Parameterized ;
26
26
import org .junit .runners .Parameterized .Parameters ;
27
+
27
28
import org .springframework .beans .factory .annotation .Autowired ;
28
29
import org .springframework .context .annotation .Bean ;
29
30
import org .springframework .context .annotation .Configuration ;
30
- import org .springframework .web .socket .*;
31
- import org .springframework .web .socket .handler .AbstractWebSocketHandler ;
32
- import org .springframework .web .socket .client .standard .StandardWebSocketClient ;
31
+ import org .springframework .web .socket .AbstractWebSocketIntegrationTests ;
32
+ import org .springframework .web .socket .JettyWebSocketTestServer ;
33
+ import org .springframework .web .socket .TomcatWebSocketTestServer ;
34
+ import org .springframework .web .socket .UndertowTestServer ;
35
+ import org .springframework .web .socket .WebSocketSession ;
33
36
import org .springframework .web .socket .client .jetty .JettyWebSocketClient ;
37
+ import org .springframework .web .socket .client .standard .StandardWebSocketClient ;
38
+ import org .springframework .web .socket .handler .AbstractWebSocketHandler ;
34
39
import org .springframework .web .socket .server .HandshakeHandler ;
35
40
import org .springframework .web .socket .sockjs .transport .handler .WebSocketTransportHandler ;
36
41
@@ -48,20 +53,20 @@ public class WebSocketConfigurationTests extends AbstractWebSocketIntegrationTes
48
53
public static Iterable <Object []> arguments () {
49
54
return Arrays .asList (new Object [][] {
50
55
{new JettyWebSocketTestServer (), new JettyWebSocketClient ()},
51
- {new TomcatWebSocketTestServer (), new StandardWebSocketClient ()},
52
- {new UndertowTestServer (), new StandardWebSocketClient ()}
56
+ {new TomcatWebSocketTestServer (), new StandardWebSocketClient ()}
57
+ // {new UndertowTestServer(), new StandardWebSocketClient()}
58
+ // TODO: Undertow tests fail against OpenJDK 8 build 124 with a BindException
53
59
});
54
- };
60
+ }
55
61
56
62
57
63
@ Override
58
64
protected Class <?>[] getAnnotatedConfigClasses () {
59
- return new Class <?>[] { TestWebSocketConfigurer .class };
65
+ return new Class <?>[] {TestWebSocketConfigurer .class };
60
66
}
61
67
62
68
@ Test
63
69
public void registerWebSocketHandler () throws Exception {
64
-
65
70
WebSocketSession session = this .webSocketClient .doHandshake (
66
71
new AbstractWebSocketHandler () {}, getWsBaseUrl () + "/ws" ).get ();
67
72
@@ -73,7 +78,6 @@ public void registerWebSocketHandler() throws Exception {
73
78
74
79
@ Test
75
80
public void registerWebSocketHandlerWithSockJS () throws Exception {
76
-
77
81
WebSocketSession session = this .webSocketClient .doHandshake (
78
82
new AbstractWebSocketHandler () {}, getWsBaseUrl () + "/sockjs/websocket" ).get ();
79
83
@@ -91,13 +95,10 @@ static class TestWebSocketConfigurer implements WebSocketConfigurer {
91
95
@ Autowired
92
96
private HandshakeHandler handshakeHandler ; // can't rely on classpath for server detection
93
97
94
-
95
98
@ Override
96
99
public void registerWebSocketHandlers (WebSocketHandlerRegistry registry ) {
97
-
98
100
registry .addHandler (serverHandler (), "/ws" )
99
101
.setHandshakeHandler (this .handshakeHandler );
100
-
101
102
registry .addHandler (serverHandler (), "/sockjs" ).withSockJS ()
102
103
.setTransportHandlerOverrides (new WebSocketTransportHandler (this .handshakeHandler ));
103
104
}
0 commit comments