Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
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.java19
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());
}
}

Back to the top