|
13 | 13 |
|
14 | 14 | package examples; |
15 | 15 |
|
| 16 | +import java.lang.management.ManagementFactory; |
16 | 17 | import java.net.URI; |
17 | 18 | import java.util.concurrent.TimeUnit; |
18 | 19 | import javax.websocket.ClientEndpointConfig; |
|
21 | 22 | import org.eclipse.jetty.client.HttpClient; |
22 | 23 | import org.eclipse.jetty.client.http.HttpClientTransportOverHTTP; |
23 | 24 | import org.eclipse.jetty.io.ClientConnector; |
| 25 | +import org.eclipse.jetty.jmx.MBeanContainer; |
| 26 | +import org.eclipse.jetty.util.component.Container; |
24 | 27 | import org.eclipse.jetty.util.component.LifeCycle; |
25 | 28 | import org.eclipse.jetty.util.ssl.SslContextFactory; |
26 | | -import org.eclipse.jetty.websocket.javax.client.internal.JavaxWebSocketClientContainer; |
| 29 | +import org.eclipse.jetty.websocket.javax.client.JavaxWebSocketClientContainerProvider; |
27 | 30 |
|
28 | 31 | public class SecureClientContainerExample |
29 | 32 | { |
@@ -76,9 +79,12 @@ public static WebSocketContainer getConfiguredWebSocketContainer() throws Except |
76 | 79 | clientConnector.setSslContextFactory(ssl); |
77 | 80 |
|
78 | 81 | HttpClient httpClient = new HttpClient(new HttpClientTransportOverHTTP(clientConnector)); |
79 | | - JavaxWebSocketClientContainer clientContainer = new JavaxWebSocketClientContainer(httpClient); |
80 | | - clientContainer.addManaged(httpClient); // allow clientContainer to own httpClient (for start/stop lifecycle) |
81 | | - clientContainer.start(); |
| 82 | + WebSocketContainer clientContainer = JavaxWebSocketClientContainerProvider.getContainer(httpClient); |
| 83 | + |
| 84 | + // Components can be added as a bean to the WebSocketContainer with the Container static method. |
| 85 | + MBeanContainer mbeanContainer = new MBeanContainer(ManagementFactory.getPlatformMBeanServer()); |
| 86 | + Container.addBean(clientContainer, mbeanContainer); |
| 87 | + |
82 | 88 | return clientContainer; |
83 | 89 | } |
84 | 90 | } |
0 commit comments