@@ -156,48 +156,6 @@ public void testRetryNonBlockingAsyncConnect() throws IOException, InterruptedEx
156
156
}
157
157
}
158
158
159
- @ Test
160
- public void testRetryBlocking () throws IOException , InterruptedException , ExecutionException {
161
-
162
- NettyAsyncHttpProviderConfig nettyConfig = new NettyAsyncHttpProviderConfig ();
163
- nettyConfig .setUseBlockingIO (true );
164
-
165
- AsyncHttpClientConfig config = new AsyncHttpClientConfig .Builder ()//
166
- .setAllowPoolingConnection (true )//
167
- .setMaximumConnectionsTotal (100 )//
168
- .setConnectionTimeoutInMs (60000 )//
169
- .setRequestTimeoutInMs (30000 )//
170
- .setAsyncHttpClientProviderConfig (nettyConfig )//
171
- .build ();
172
-
173
- AsyncHttpClient client = getAsyncHttpClient (config );
174
-
175
- try {
176
- List <ListenableFuture <Response >> res = new ArrayList <ListenableFuture <Response >>();
177
- for (int i = 0 ; i < 32 ; i ++) {
178
- res .add (testMethodRequest (client , 3 , "servlet" , UUID .randomUUID ().toString ()));
179
- }
180
-
181
- StringBuilder b = new StringBuilder ();
182
- for (ListenableFuture <Response > r : res ) {
183
- Response theres = r .get ();
184
- assertEquals (theres .getStatusCode (), 200 );
185
- b .append ("==============\r \n " );
186
- b .append ("Response Headers\r \n " );
187
- Map <String , List <String >> heads = theres .getHeaders ();
188
- b .append (heads + "\r \n " );
189
- b .append ("==============\r \n " );
190
- assertTrue (heads .size () > 0 );
191
-
192
- }
193
- System .out .println (b .toString ());
194
- System .out .flush ();
195
-
196
- } finally {
197
- client .close ();
198
- }
199
- }
200
-
201
159
@ SuppressWarnings ("serial" )
202
160
public class MockExceptionServlet extends HttpServlet {
203
161
0 commit comments