1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27 package org.apache.hc.client5.testing.sync;
28
29 import org.apache.hc.client5.http.classic.methods.HttpGet;
30 import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
31 import org.apache.hc.client5.http.impl.io.BasicHttpClientConnectionManager;
32 import org.apache.hc.core5.http.HttpHost;
33 import org.apache.hc.core5.http.io.entity.EntityUtils;
34 import org.junit.Assert;
35 import org.junit.Test;
36
37 public class TestBasicConnectionManager extends LocalServerTestBase {
38
39 @Test
40 public void testBasics() throws Exception {
41 this.clientBuilder.setConnectionManager(new BasicHttpClientConnectionManager());
42
43 final HttpHost target = start();
44 final HttpGet get = new HttpGet("/random/1024");
45 try (CloseableHttpResponse response = this.httpclient.execute(target, get)) {
46 Assert.assertEquals(200, response.getCode());
47 EntityUtils.consume(response.getEntity());
48 }
49 }
50
51 @Test(expected=IllegalStateException.class)
52 public void testConnectionStillInUse() throws Exception {
53 this.clientBuilder.setConnectionManager(new BasicHttpClientConnectionManager());
54
55 final HttpHost target = start();
56 final HttpGet get1 = new HttpGet("/random/1024");
57 this.httpclient.execute(target, get1);
58 final HttpGet get2 = new HttpGet("/random/1024");
59 this.httpclient.execute(target, get2);
60 }
61
62 }