@@ -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