|
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