@@ -92,18 +92,17 @@ public class AsyncHttpClient {
9292 private static final int DEFAULT_MAX_CONNECTIONS = 10 ;
9393 private static final int DEFAULT_SOCKET_TIMEOUT = 10 * 1000 ;
9494 private static final int DEFAULT_MAX_RETRIES = 5 ;
95- private static final String ENCODING = "UTF-8" ;
9695 private static final String HEADER_ACCEPT_ENCODING = "Accept-Encoding" ;
9796 private static final String ENCODING_GZIP = "gzip" ;
9897
9998 private static int maxConnections = DEFAULT_MAX_CONNECTIONS ;
10099 private static int socketTimeout = DEFAULT_SOCKET_TIMEOUT ;
101100
102- private DefaultHttpClient httpClient ;
103- private HttpContext httpContext ;
101+ private final DefaultHttpClient httpClient ;
102+ private final HttpContext httpContext ;
104103 private ThreadPoolExecutor threadPool ;
105- private Map <Context , List <WeakReference <Future >>> requestMap ;
106- private Map <String , String > clientHeaderMap ;
104+ private final Map <Context , List <WeakReference <Future <?> >>> requestMap ;
105+ private final Map <String , String > clientHeaderMap ;
107106
108107
109108 /**
@@ -159,7 +158,7 @@ public void process(HttpResponse response, HttpContext context) {
159158
160159 threadPool = (ThreadPoolExecutor )Executors .newCachedThreadPool ();
161160
162- requestMap = new WeakHashMap <Context , List <WeakReference <Future >>>();
161+ requestMap = new WeakHashMap <Context , List <WeakReference <Future <?> >>>();
163162 clientHeaderMap = new HashMap <String , String >();
164163 }
165164
@@ -229,10 +228,10 @@ public void addHeader(String header, String value) {
229228 * @param mayInterruptIfRunning specifies if active requests should be cancelled along with pending requests.
230229 */
231230 public void cancelRequests (Context context , boolean mayInterruptIfRunning ) {
232- List <WeakReference <Future >> requestList = requestMap .get (context );
231+ List <WeakReference <Future <?> >> requestList = requestMap .get (context );
233232 if (requestList != null ) {
234- for (WeakReference <Future > requestRef : requestList ) {
235- Future request = requestRef .get ();
233+ for (WeakReference <Future <?> > requestRef : requestList ) {
234+ Future <?> request = requestRef .get ();
236235 if (request != null ) {
237236 request .cancel (mayInterruptIfRunning );
238237 }
@@ -413,17 +412,17 @@ private void sendRequest(DefaultHttpClient client, HttpContext httpContext, Http
413412 uriRequest .addHeader ("Content-Type" , contentType );
414413 }
415414
416- Future request = threadPool .submit (new AsyncHttpRequest (client , httpContext , uriRequest , responseHandler ));
415+ Future <?> request = threadPool .submit (new AsyncHttpRequest (client , httpContext , uriRequest , responseHandler ));
417416
418417 if (context != null ) {
419418 // Add request to request map
420- List <WeakReference <Future >> requestList = requestMap .get (context );
419+ List <WeakReference <Future <?> >> requestList = requestMap .get (context );
421420 if (requestList == null ) {
422- requestList = new LinkedList <WeakReference <Future >>();
421+ requestList = new LinkedList <WeakReference <Future <?> >>();
423422 requestMap .put (context , requestList );
424423 }
425424
426- requestList .add (new WeakReference <Future >(request ));
425+ requestList .add (new WeakReference <Future <?> >(request ));
427426
428427 // TODO: Remove dead weakrefs from requestLists?
429428 }
0 commit comments