iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

further connection management work

Browse Source
This commit is contained in:
eugenp 2014-07-06 16:41:37 +03:00
parent 5991755402
commit 2b704f933a
4 changed files with 10 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
httpclient/src/test/java/org/baeldung/httpclient/HttpClientConnectionManagementTest.java → httpclient/src/test/java/org/baeldung/httpclient/conn/HttpClientConnectionManagementTest.java
View File

@ -1,4 +1,4 @@
package org.baeldung.httpclient; package org.baeldung.httpclient.conn;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
@ -109,18 +109,12 @@ public class HttpClientConnectionManagementTest {
// 3 // 3
@Test @Test
// @Ignore public final void whenPollingConnectionManagerIsConfiguredOnHttpClient_thenNoExceptions() throws InterruptedException, ClientProtocolException, IOException {
public final void whenPollingConnectionManagerIsConfiguredOnHttpClient_thenNoExceptions() throws InterruptedException {
poolingConnManager = new PoolingHttpClientConnectionManager(); poolingConnManager = new PoolingHttpClientConnectionManager();
final CloseableHttpClient client1 = HttpClients.custom().setConnectionManager(poolingConnManager).build(); client = HttpClients.custom().setConnectionManager(poolingConnManager).build();
final CloseableHttpClient client2 = HttpClients.custom().setConnectionManager(poolingConnManager).build(); client.execute(get1);
final TesterVersion_MultiHttpClientConnThread thread1 = new TesterVersion_MultiHttpClientConnThread(client1, get1, poolingConnManager);
final TesterVersion_MultiHttpClientConnThread thread2 = new TesterVersion_MultiHttpClientConnThread(client2, get2, poolingConnManager); assertTrue(poolingConnManager.getTotalStats().getLeased() == 1);
thread1.start();
thread1.join();
thread2.start();
thread2.join(1000);
assertTrue(poolingConnManager.getTotalStats().getLeased() == 2);
} }
@Test @Test
@ -149,8 +143,8 @@ public class HttpClientConnectionManagementTest {
final MultiHttpClientConnThread thread1 = new MultiHttpClientConnThread(client1, get1); final MultiHttpClientConnThread thread1 = new MultiHttpClientConnThread(client1, get1);
final MultiHttpClientConnThread thread2 = new MultiHttpClientConnThread(client2, get2); final MultiHttpClientConnThread thread2 = new MultiHttpClientConnThread(client2, get2);
thread1.start(); thread1.start();
thread1.join();
thread2.start(); thread2.start();
thread1.join();
thread2.join(); thread2.join();
} }

2
httpclient/src/test/java/org/baeldung/httpclient/IdleConnectionMonitorThread.java → httpclient/src/test/java/org/baeldung/httpclient/conn/IdleConnectionMonitorThread.java
View File

@ -1,4 +1,4 @@
package org.baeldung.httpclient; package org.baeldung.httpclient.conn;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;

2
httpclient/src/test/java/org/baeldung/httpclient/MultiHttpClientConnThread.java → httpclient/src/test/java/org/baeldung/httpclient/conn/MultiHttpClientConnThread.java
View File

@ -1,4 +1,4 @@
package org.baeldung.httpclient; package org.baeldung.httpclient.conn;
import java.io.IOException; import java.io.IOException;
import java.util.logging.Level; import java.util.logging.Level;

2
httpclient/src/test/java/org/baeldung/httpclient/TesterVersion_MultiHttpClientConnThread.java → httpclient/src/test/java/org/baeldung/httpclient/conn/TesterVersion_MultiHttpClientConnThread.java
View File

@ -1,4 +1,4 @@
package org.baeldung.httpclient; package org.baeldung.httpclient.conn;
import java.io.IOException; import java.io.IOException;
import java.util.logging.Level; import java.util.logging.Level;