156157158159160161162163164165166
{ e.printStackTrace(); } finally { httpClient.stop(); } } finally { serverThread.join();
233234235236237238239240241242243
assertTrue("elapsed=" + elapsed + ", processing=" + processingTime, elapsed <= processingTime); assertTrue(latch.await(2000 + 2 * processingTime, TimeUnit.MILLISECONDS)); } finally { httpClient.stop(); } } finally { serverThread.join();
276277278279280281282283284285286
assertTrue(latch.await(5, TimeUnit.SECONDS)); } finally { httpClient.stop(); } } @Test public void testSendWithServerCrash() throws Exception
338339340341342343344345346347348
assertTrue("elapsed=" + elapsed + ", processing=" + processingTime, elapsed <= processingTime); assertTrue(latch.await(2 * processingTime, TimeUnit.MILLISECONDS)); } finally { httpClient.stop(); } } finally { serverThread.join();
417418419420421422423424425426427
assertTrue(latch.await(2 * timeout, TimeUnit.MILLISECONDS)); } finally { httpClient.stop(); } } finally { serverThread.join();