diff options
Diffstat (limited to 'jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientExplicitConnectionTest.java')
-rw-r--r-- | jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientExplicitConnectionTest.java | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientExplicitConnectionTest.java b/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientExplicitConnectionTest.java index c49b37b97d..6b7acc6a19 100644 --- a/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientExplicitConnectionTest.java +++ b/jetty-client/src/test/java/org/eclipse/jetty/client/HttpClientExplicitConnectionTest.java @@ -24,6 +24,9 @@ import org.eclipse.jetty.client.api.Connection; import org.eclipse.jetty.client.api.ContentResponse; import org.eclipse.jetty.client.api.Destination; import org.eclipse.jetty.client.api.Request; +import org.eclipse.jetty.client.http.HttpConnectionOverHTTP; +import org.eclipse.jetty.client.http.HttpConnectionPool; +import org.eclipse.jetty.client.http.HttpDestinationOverHTTP; import org.eclipse.jetty.client.util.FutureResponseListener; import org.eclipse.jetty.toolchain.test.annotation.Slow; import org.eclipse.jetty.util.FuturePromise; @@ -56,9 +59,10 @@ public class HttpClientExplicitConnectionTest extends AbstractHttpClientServerTe Assert.assertNotNull(response); Assert.assertEquals(200, response.getStatus()); - HttpDestination httpDestination = (HttpDestination)destination; - Assert.assertTrue(httpDestination.getActiveConnections().isEmpty()); - Assert.assertTrue(httpDestination.getIdleConnections().isEmpty()); + HttpDestinationOverHTTP httpDestination = (HttpDestinationOverHTTP)destination; + HttpConnectionPool connectionPool = httpDestination.getHttpConnectionPool(); + Assert.assertTrue(connectionPool.getActiveConnections().isEmpty()); + Assert.assertTrue(connectionPool.getIdleConnections().isEmpty()); } } @@ -84,11 +88,12 @@ public class HttpClientExplicitConnectionTest extends AbstractHttpClientServerTe // Give the connection some time to process the remote close TimeUnit.SECONDS.sleep(1); - HttpConnection httpConnection = (HttpConnection)connection; + HttpConnectionOverHTTP httpConnection = (HttpConnectionOverHTTP)connection; Assert.assertFalse(httpConnection.getEndPoint().isOpen()); - HttpDestination httpDestination = (HttpDestination)destination; - Assert.assertTrue(httpDestination.getActiveConnections().isEmpty()); - Assert.assertTrue(httpDestination.getIdleConnections().isEmpty()); + HttpDestinationOverHTTP httpDestination = (HttpDestinationOverHTTP)destination; + HttpConnectionPool connectionPool = httpDestination.getHttpConnectionPool(); + Assert.assertTrue(connectionPool.getActiveConnections().isEmpty()); + Assert.assertTrue(connectionPool.getIdleConnections().isEmpty()); } } |