hc-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ol...@apache.org
Subject svn commit: r1630965 [1/2] - in /httpcomponents/httpasyncclient/trunk: httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/ httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/ httpasyncclient/src/examples/org/apache...
Date Fri, 10 Oct 2014 19:48:56 GMT
Author: olegk
Date: Fri Oct 10 19:48:55 2014
New Revision: 1630965

URL: http://svn.apache.org/r1630965
Log:
Missing @Override annotations

Modified:
    httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/AsynchronousAsyncValidationRequest.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/CachingHttpAsyncClient.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/ChainedFutureCallback.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/CachingHttpAsyncClientExecChain.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/ClientExecChainAsyncClient.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientEvictExpiredConnections.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientHttpExchangeFutureCallback.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/QuickStart.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/AbstractHttpAsyncClient.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultAsyncRequestDirector.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultResultCallback.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnection.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnectionFactory.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultHttpAsyncRoutePlanner.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/HttpNIOConnPoolFactory.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/ManagedClientAsyncConnectionImpl.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/PoolingClientAsyncConnectionManager.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/SSLLayeringStrategy.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/TrustManagerDecorator.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClient.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClientBase.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultAsyncUserTokenHandler.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultClientExchangeHandlerImpl.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalHttpAsyncClient.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalIOReactorExceptionHandler.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalClientExec.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalHttpAsyncClient.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionFactory.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionImpl.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/PoolingNHttpClientConnectionManager.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/client/methods/BaseZeroCopyRequestProducer.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/NoopIOSessionStrategy.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/ssl/SSLIOSessionStrategy.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/EchoHandler.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RandomHandler.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RequestBasicAuth.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/ResponseBasicUnauthorized.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/nio/client/integration/TestClientAuthentication.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/nio/client/integration/TestClientAuthenticationFallBack.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/nio/client/integration/TestClientReauthentication.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/nio/client/integration/TestHttpAsyncPrematureTermination.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/nio/client/integration/TestRedirects.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/nio/client/integration/TestStatefulConnManagement.java
    httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/nio/client/methods/TestZeroCopy.java

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/AsynchronousAsyncValidationRequest.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/AsynchronousAsyncValidationRequest.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/AsynchronousAsyncValidationRequest.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/AsynchronousAsyncValidationRequest.java Fri Oct 10 19:48:55 2014
@@ -70,16 +70,20 @@ class AsynchronousAsyncValidationRequest
         this.identifier = identifier;
     }
 
+    @Override
     public void run() {
         try {
             final FutureCallback<HttpResponse> callback = new FutureCallback<HttpResponse>() {
 
+                @Override
                 public void cancelled() {
                 }
 
+                @Override
                 public void completed(final HttpResponse httpResponse) {
                 }
 
+                @Override
                 public void failed(final Exception e) {
                     log.debug("Asynchronous revalidation failed", e);
                 }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/CachingHttpAsyncClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/CachingHttpAsyncClient.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/CachingHttpAsyncClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/CachingHttpAsyncClient.java Fri Oct 10 19:48:55 2014
@@ -237,6 +237,7 @@ public class CachingHttpAsyncClient impl
         return this.cacheUpdates.get();
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpHost target,
             final HttpRequest request,
@@ -244,6 +245,7 @@ public class CachingHttpAsyncClient impl
         return execute(target, request, null, callback);
     }
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,
@@ -251,6 +253,7 @@ public class CachingHttpAsyncClient impl
         return execute(requestProducer, responseConsumer, null, callback);
     }
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,
@@ -260,12 +263,14 @@ public class CachingHttpAsyncClient impl
         return this.backend.execute(requestProducer, responseConsumer, context, callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpUriRequest request,
             final FutureCallback<HttpResponse> callback) {
         return execute(request, null, callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpUriRequest request,
             final HttpContext context,
@@ -275,6 +280,7 @@ public class CachingHttpAsyncClient impl
         return execute(httpHost, request, context, callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpHost target,
             final HttpRequest originalRequest,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/ChainedFutureCallback.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/ChainedFutureCallback.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/ChainedFutureCallback.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/main/java/org/apache/http/impl/client/cache/ChainedFutureCallback.java Fri Oct 10 19:48:55 2014
@@ -37,14 +37,17 @@ class ChainedFutureCallback<T> implement
         this.wrapped = delegate;
     }
 
+    @Override
     public void completed(final T result) {
         this.wrapped.completed(result);
     }
 
+    @Override
     public void failed(final Exception ex) {
         this.wrapped.failed(ex);
     }
 
+    @Override
     public void cancelled() {
         this.wrapped.cancel();
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/CachingHttpAsyncClientExecChain.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/CachingHttpAsyncClientExecChain.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/CachingHttpAsyncClientExecChain.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/CachingHttpAsyncClientExecChain.java Fri Oct 10 19:48:55 2014
@@ -91,6 +91,7 @@ public class CachingHttpAsyncClientExecC
         return execute(route, request, context, null);
     }
 
+    @Override
     public CloseableHttpResponse execute(
             final HttpRoute route,
             final HttpRequestWrapper request,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/ClientExecChainAsyncClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/ClientExecChainAsyncClient.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/ClientExecChainAsyncClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient-cache/src/test/java/org/apache/http/impl/client/cache/ClientExecChainAsyncClient.java Fri Oct 10 19:48:55 2014
@@ -84,10 +84,12 @@ public class ClientExecChainAsyncClient 
         return null;
     }
 
+    @Override
     public void close() throws IOException {
         // no-op
     }
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientEvictExpiredConnections.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientEvictExpiredConnections.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientEvictExpiredConnections.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientEvictExpiredConnections.java Fri Oct 10 19:48:55 2014
@@ -70,16 +70,19 @@ public class AsyncClientEvictExpiredConn
                 final HttpGet httpget = new HttpGet(uri);
                 httpclient.execute(httpget, new FutureCallback<HttpResponse>() {
 
+                    @Override
                     public void completed(final HttpResponse response) {
                         latch.countDown();
                         System.out.println(httpget.getRequestLine() + "->" + response.getStatusLine());
                     }
 
+                    @Override
                     public void failed(final Exception ex) {
                         latch.countDown();
                         System.out.println(httpget.getRequestLine() + "->" + ex);
                     }
 
+                    @Override
                     public void cancelled() {
                         latch.countDown();
                         System.out.println(httpget.getRequestLine() + " cancelled");

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientHttpExchangeFutureCallback.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientHttpExchangeFutureCallback.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientHttpExchangeFutureCallback.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/AsyncClientHttpExchangeFutureCallback.java Fri Oct 10 19:48:55 2014
@@ -59,16 +59,19 @@ public class AsyncClientHttpExchangeFutu
             for (final HttpGet request: requests) {
                 httpclient.execute(request, new FutureCallback<HttpResponse>() {
 
+                    @Override
                     public void completed(final HttpResponse response) {
                         latch.countDown();
                         System.out.println(request.getRequestLine() + "->" + response.getStatusLine());
                     }
 
+                    @Override
                     public void failed(final Exception ex) {
                         latch.countDown();
                         System.out.println(request.getRequestLine() + "->" + ex);
                     }
 
+                    @Override
                     public void cancelled() {
                         latch.countDown();
                         System.out.println(request.getRequestLine() + " cancelled");

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/QuickStart.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/QuickStart.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/QuickStart.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/examples/org/apache/http/examples/nio/client/QuickStart.java Fri Oct 10 19:48:55 2014
@@ -62,16 +62,19 @@ public class QuickStart {
             final HttpGet request2 = new HttpGet("http://www.apache.org/");
             httpclient.execute(request2, new FutureCallback<HttpResponse>() {
 
+                @Override
                 public void completed(final HttpResponse response2) {
                     latch1.countDown();
                     System.out.println(request2.getRequestLine() + "->" + response2.getStatusLine());
                 }
 
+                @Override
                 public void failed(final Exception ex) {
                     latch1.countDown();
                     System.out.println(request2.getRequestLine() + "->" + ex);
                 }
 
+                @Override
                 public void cancelled() {
                     latch1.countDown();
                     System.out.println(request2.getRequestLine() + " cancelled");
@@ -111,16 +114,19 @@ public class QuickStart {
             };
             httpclient.execute(producer3, consumer3, new FutureCallback<HttpResponse>() {
 
+                @Override
                 public void completed(final HttpResponse response3) {
                     latch2.countDown();
                     System.out.println(request2.getRequestLine() + "->" + response3.getStatusLine());
                 }
 
+                @Override
                 public void failed(final Exception ex) {
                     latch2.countDown();
                     System.out.println(request2.getRequestLine() + "->" + ex);
                 }
 
+                @Override
                 public void cancelled() {
                     latch2.countDown();
                     System.out.println(request2.getRequestLine() + " cancelled");

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/AbstractHttpAsyncClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/AbstractHttpAsyncClient.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/AbstractHttpAsyncClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/AbstractHttpAsyncClient.java Fri Oct 10 19:48:55 2014
@@ -501,6 +501,7 @@ public abstract class AbstractHttpAsyncC
         }
     }
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,
@@ -542,6 +543,7 @@ public abstract class AbstractHttpAsyncC
         return future;
     }
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,
@@ -549,6 +551,7 @@ public abstract class AbstractHttpAsyncC
         return execute(requestProducer, responseConsumer, new BasicHttpContext(), callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpHost target, final HttpRequest request, final HttpContext context,
             final FutureCallback<HttpResponse> callback) {
@@ -558,18 +561,21 @@ public abstract class AbstractHttpAsyncC
                 context, callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpHost target, final HttpRequest request,
             final FutureCallback<HttpResponse> callback) {
         return execute(target, request, new BasicHttpContext(), callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpUriRequest request,
             final FutureCallback<HttpResponse> callback) {
         return execute(request, new BasicHttpContext(), callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpUriRequest request,
             final HttpContext context,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultAsyncRequestDirector.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultAsyncRequestDirector.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultAsyncRequestDirector.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultAsyncRequestDirector.java Fri Oct 10 19:48:55 2014
@@ -177,6 +177,7 @@ class DefaultAsyncRequestDirector<T> imp
         this.id = COUNTER.getAndIncrement();
     }
 
+    @Override
     public void close() {
         if (this.closed) {
             return;
@@ -218,9 +219,11 @@ class DefaultAsyncRequestDirector<T> imp
             if (request instanceof AbortableHttpRequest) {
                 ((AbortableHttpRequest) request).setReleaseTrigger(new ConnectionReleaseTrigger() {
 
+                    @Override
                     public void releaseConnection() throws IOException {
                     }
 
+                    @Override
                     public void abortConnection() throws IOException {
                         cancel();
                     }
@@ -241,10 +244,12 @@ class DefaultAsyncRequestDirector<T> imp
         }
     }
 
+    @Override
     public HttpHost getTarget() {
         return this.requestProducer.getTarget();
     }
 
+    @Override
     public synchronized HttpRequest generateRequest() throws IOException, HttpException {
         final HttpRoute route = this.mainRequest.getRoute();
         if (!this.routeEstablished) {
@@ -321,6 +326,7 @@ class DefaultAsyncRequestDirector<T> imp
         return this.currentRequest;
     }
 
+    @Override
     public synchronized void produceContent(
             final ContentEncoder encoder, final IOControl ioctrl) throws IOException {
         if (this.log.isDebugEnabled()) {
@@ -333,6 +339,7 @@ class DefaultAsyncRequestDirector<T> imp
         }
     }
 
+    @Override
     public void requestCompleted(final HttpContext context) {
         if (this.log.isDebugEnabled()) {
             this.log.debug("[exchange: " + this.id + "] Request completed");
@@ -341,15 +348,18 @@ class DefaultAsyncRequestDirector<T> imp
         this.requestProducer.requestCompleted(context);
     }
 
+    @Override
     public boolean isRepeatable() {
         return this.requestProducer.isRepeatable();
     }
 
+    @Override
     public void resetRequest() throws IOException {
         this.requestSent = false;
         this.requestProducer.resetRequest();
     }
 
+    @Override
     public synchronized void responseReceived(
             final HttpResponse response) throws IOException, HttpException {
         if (this.log.isDebugEnabled()) {
@@ -392,6 +402,7 @@ class DefaultAsyncRequestDirector<T> imp
         }
     }
 
+    @Override
     public synchronized void consumeContent(
             final ContentDecoder decoder, final IOControl ioctrl) throws IOException {
         if (this.log.isDebugEnabled()) {
@@ -423,6 +434,7 @@ class DefaultAsyncRequestDirector<T> imp
         }
     }
 
+    @Override
     public synchronized void failed(final Exception ex) {
         try {
             if (!this.requestSent) {
@@ -438,6 +450,7 @@ class DefaultAsyncRequestDirector<T> imp
         }
     }
 
+    @Override
     public synchronized void responseCompleted(final HttpContext context) {
         if (this.log.isDebugEnabled()) {
             this.log.debug("[exchange: " + this.id + "] Response fully read");
@@ -522,6 +535,7 @@ class DefaultAsyncRequestDirector<T> imp
         }
     }
 
+    @Override
     public synchronized boolean cancel() {
         if (this.log.isDebugEnabled()) {
             this.log.debug("[exchange: " + this.id + "] Cancelled");
@@ -547,14 +561,17 @@ class DefaultAsyncRequestDirector<T> imp
         }
     }
 
+    @Override
     public boolean isDone() {
         return this.resultCallback.isDone();
     }
 
+    @Override
     public T getResult() {
         return this.responseConsumer.getResult();
     }
 
+    @Override
     public Exception getException() {
         return this.responseConsumer.getException();
     }
@@ -614,14 +631,17 @@ class DefaultAsyncRequestDirector<T> imp
 
     class InternalFutureCallback implements FutureCallback<ManagedClientAsyncConnection> {
 
+        @Override
         public void completed(final ManagedClientAsyncConnection session) {
             connectionRequestCompleted(session);
         }
 
+        @Override
         public void failed(final Exception ex) {
             connectionRequestFailed(ex);
         }
 
+        @Override
         public void cancelled() {
             connectionRequestCancelled();
         }
@@ -858,14 +878,17 @@ class DefaultAsyncRequestDirector<T> imp
         return null;
     }
 
+    @Override
     public HttpContext getContext() {
         return this.localContext;
     }
 
+    @Override
     public HttpProcessor getHttpProcessor() {
         return this.httppocessor;
     }
 
+    @Override
     public ConnectionReuseStrategy getConnectionReuseStrategy() {
         return this.reuseStrategy;
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultResultCallback.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultResultCallback.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultResultCallback.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/client/DefaultResultCallback.java Fri Oct 10 19:48:55 2014
@@ -44,21 +44,25 @@ class DefaultResultCallback<T> implement
         this.queue = queue;
     }
 
+    @Override
     public void completed(final T result, final HttpAsyncRequestExecutionHandler<T> handler) {
         this.future.completed(result);
         this.queue.remove(handler);
     }
 
+    @Override
     public void failed(final Exception ex, final HttpAsyncRequestExecutionHandler<T> handler) {
         this.future.failed(ex);
         this.queue.remove(handler);
     }
 
+    @Override
     public void cancelled(final HttpAsyncRequestExecutionHandler<T> handler) {
         this.future.cancel(true);
         this.queue.remove(handler);
     }
 
+    @Override
     public boolean isDone() {
         return this.future.isDone();
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnection.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnection.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnection.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnection.java Fri Oct 10 19:48:55 2014
@@ -64,6 +64,7 @@ public class DefaultClientAsyncConnectio
         }
     }
 
+    @Override
     public void upgrade(final IOSession iosession) {
         this.original = iosession;
         if (this.log.isDebugEnabled() || this.wirelog.isDebugEnabled()) {
@@ -74,6 +75,7 @@ public class DefaultClientAsyncConnectio
         }
     }
 
+    @Override
     public IOSession getIOSession() {
         return this.original;
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnectionFactory.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnectionFactory.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnectionFactory.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultClientAsyncConnectionFactory.java Fri Oct 10 19:48:55 2014
@@ -85,6 +85,7 @@ public class DefaultClientAsyncConnectio
         this.allocator = createByteBufferAllocator();
     }
 
+    @Override
     @Deprecated
     public ClientAsyncConnection create(
             final String id,
@@ -104,6 +105,7 @@ public class DefaultClientAsyncConnectio
         return DefaultHttpResponseFactory.INSTANCE;
     }
 
+    @Override
     public ManagedNHttpClientConnection create(
             final IOSession iosession, final ConnectionConfig config) {
         final String id = "http-outgoing-" + Long.toString(COUNTER.getAndIncrement());

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultHttpAsyncRoutePlanner.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultHttpAsyncRoutePlanner.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultHttpAsyncRoutePlanner.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/DefaultHttpAsyncRoutePlanner.java Fri Oct 10 19:48:55 2014
@@ -60,6 +60,7 @@ public class DefaultHttpAsyncRoutePlanne
         return reg;
     }
 
+    @Override
     public HttpRoute determineRoute(
             final HttpHost target,
             final HttpRequest request,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/HttpNIOConnPoolFactory.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/HttpNIOConnPoolFactory.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/HttpNIOConnPoolFactory.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/HttpNIOConnPoolFactory.java Fri Oct 10 19:48:55 2014
@@ -35,6 +35,7 @@ import org.apache.http.nio.reactor.IOSes
 @Deprecated
 class HttpNIOConnPoolFactory implements NIOConnFactory<HttpRoute, IOSession> {
 
+    @Override
     public IOSession create(final HttpRoute route, final IOSession session) throws IOException {
         return session;
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/ManagedClientAsyncConnectionImpl.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/ManagedClientAsyncConnectionImpl.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/ManagedClientAsyncConnectionImpl.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/ManagedClientAsyncConnectionImpl.java Fri Oct 10 19:48:55 2014
@@ -115,6 +115,7 @@ class ManagedClientAsyncConnectionImpl i
         return local;
     }
 
+    @Override
     public void close() throws IOException {
         final ClientAsyncConnection conn = getConnection();
         if (conn != null) {
@@ -122,6 +123,7 @@ class ManagedClientAsyncConnectionImpl i
         }
     }
 
+    @Override
     public void shutdown() throws IOException {
         final ClientAsyncConnection conn = getConnection();
         if (conn != null) {
@@ -129,6 +131,7 @@ class ManagedClientAsyncConnectionImpl i
         }
     }
 
+    @Override
     public boolean isOpen() {
         final ClientAsyncConnection conn = getConnection();
         if (conn != null) {
@@ -138,115 +141,138 @@ class ManagedClientAsyncConnectionImpl i
         }
     }
 
+    @Override
     public boolean isStale() {
         return isOpen();
     }
 
+    @Override
     public void setSocketTimeout(final int timeout) {
         final ClientAsyncConnection conn = ensureConnection();
         conn.setSocketTimeout(timeout);
     }
 
+    @Override
     public int getSocketTimeout() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getSocketTimeout();
     }
 
+    @Override
     public HttpConnectionMetrics getMetrics() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getMetrics();
     }
 
+    @Override
     public InetAddress getLocalAddress() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getLocalAddress();
     }
 
+    @Override
     public int getLocalPort() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getLocalPort();
     }
 
+    @Override
     public InetAddress getRemoteAddress() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getRemoteAddress();
     }
 
+    @Override
     public int getRemotePort() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getRemotePort();
     }
 
+    @Override
     public int getStatus() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getStatus();
     }
 
+    @Override
     public HttpRequest getHttpRequest() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getHttpRequest();
     }
 
+    @Override
     public HttpResponse getHttpResponse() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getHttpResponse();
     }
 
+    @Override
     public HttpContext getContext() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getContext();
     }
 
+    @Override
     public void requestInput() {
         final ClientAsyncConnection conn = ensureConnection();
         conn.requestInput();
     }
 
+    @Override
     public void suspendInput() {
         final ClientAsyncConnection conn = ensureConnection();
         conn.suspendInput();
     }
 
+    @Override
     public void requestOutput() {
         final ClientAsyncConnection conn = ensureConnection();
         conn.requestOutput();
     }
 
+    @Override
     public void suspendOutput() {
         final ClientAsyncConnection conn = ensureConnection();
         conn.suspendOutput();
     }
 
+    @Override
     public void submitRequest(final HttpRequest request) throws IOException, HttpException {
         final ClientAsyncConnection conn = ensureConnection();
         conn.submitRequest(request);
     }
 
+    @Override
     public boolean isRequestSubmitted() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.isRequestSubmitted();
     }
 
+    @Override
     public void resetOutput() {
         final ClientAsyncConnection conn = ensureConnection();
         conn.resetOutput();
     }
 
+    @Override
     public void resetInput() {
         final ClientAsyncConnection conn = ensureConnection();
         conn.resetInput();
     }
 
+    @Override
     public boolean isSecure() {
         final ClientAsyncConnection conn = ensureConnection();
         return conn.getIOSession() instanceof SSLIOSession;
     }
 
+    @Override
     public HttpRoute getRoute() {
         final HttpPoolEntry entry = ensurePoolEntry();
         return entry.getEffectiveRoute();
     }
 
+    @Override
     public SSLSession getSSLSession() {
         final ClientAsyncConnection conn = ensureConnection();
         final IOSession iosession = conn.getIOSession();
@@ -257,28 +283,34 @@ class ManagedClientAsyncConnectionImpl i
         }
     }
 
+    @Override
     public Object getState() {
         final HttpPoolEntry entry = ensurePoolEntry();
         return entry.getState();
     }
 
+    @Override
     public void setState(final Object state) {
         final HttpPoolEntry entry = ensurePoolEntry();
         entry.setState(state);
     }
 
+    @Override
     public void markReusable() {
         this.reusable = true;
     }
 
+    @Override
     public void unmarkReusable() {
         this.reusable = false;
     }
 
+    @Override
     public boolean isMarkedReusable() {
         return this.reusable;
     }
 
+    @Override
     public void setIdleDuration(final long duration, final TimeUnit unit) {
         if(duration > 0) {
             this.duration = unit.toMillis(duration);
@@ -296,6 +328,7 @@ class ManagedClientAsyncConnectionImpl i
         return reg;
     }
 
+    @Override
     public synchronized void open(
             final HttpRoute route,
             final HttpContext context,
@@ -331,6 +364,7 @@ class ManagedClientAsyncConnectionImpl i
         }
     }
 
+    @Override
     public synchronized void tunnelProxy(
             final HttpHost next, final HttpParams params) throws IOException {
         final HttpPoolEntry entry = ensurePoolEntry();
@@ -341,6 +375,7 @@ class ManagedClientAsyncConnectionImpl i
         tracker.tunnelProxy(next, false);
     }
 
+    @Override
     public synchronized void tunnelTarget(
             final HttpParams params) throws IOException {
         final HttpPoolEntry entry = ensurePoolEntry();
@@ -354,6 +389,7 @@ class ManagedClientAsyncConnectionImpl i
         tracker.tunnelTarget(false);
     }
 
+    @Override
     public synchronized void layerProtocol(
             final HttpContext context, final HttpParams params) throws IOException {
         final HttpPoolEntry entry = ensurePoolEntry();
@@ -381,6 +417,7 @@ class ManagedClientAsyncConnectionImpl i
         tracker.layerProtocol(layeringStrategy.isSecure());
     }
 
+    @Override
     public synchronized void releaseConnection() {
         if (this.poolEntry == null) {
             return;
@@ -389,6 +426,7 @@ class ManagedClientAsyncConnectionImpl i
         this.poolEntry = null;
     }
 
+    @Override
     public synchronized void abortConnection() {
         if (this.poolEntry == null) {
             return;

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/PoolingClientAsyncConnectionManager.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/PoolingClientAsyncConnectionManager.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/PoolingClientAsyncConnectionManager.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/impl/nio/conn/PoolingClientAsyncConnectionManager.java Fri Oct 10 19:48:55 2014
@@ -96,24 +96,29 @@ public class PoolingClientAsyncConnectio
         return new DefaultClientAsyncConnectionFactory();
     }
 
+    @Override
     public AsyncSchemeRegistry getSchemeRegistry() {
         return this.schemeRegistry;
     }
 
+    @Override
     public void execute(final IOEventDispatch eventDispatch) throws IOException {
         this.ioreactor.execute(eventDispatch);
     }
 
+    @Override
     public IOReactorStatus getStatus() {
         return this.ioreactor.getStatus();
     }
 
+    @Override
     public void shutdown(final long waitMs) throws IOException {
         this.log.debug("Connection manager is shutting down");
         this.pool.shutdown(waitMs);
         this.log.debug("Connection manager shut down");
     }
 
+    @Override
     public void shutdown() throws IOException {
         this.log.debug("Connection manager is shutting down");
         this.pool.shutdown(2000);
@@ -152,6 +157,7 @@ public class PoolingClientAsyncConnectio
         return buf.toString();
     }
 
+    @Override
     public Future<ManagedClientAsyncConnection> leaseConnection(
             final HttpRoute route,
             final Object state,
@@ -169,6 +175,7 @@ public class PoolingClientAsyncConnectio
         return future;
     }
 
+    @Override
     public void releaseConnection(
             final ManagedClientAsyncConnection conn,
             final long keepalive,
@@ -226,34 +233,42 @@ public class PoolingClientAsyncConnectio
         }
     }
 
+    @Override
     public PoolStats getTotalStats() {
         return this.pool.getTotalStats();
     }
 
+    @Override
     public PoolStats getStats(final HttpRoute route) {
         return this.pool.getStats(route);
     }
 
+    @Override
     public void setMaxTotal(final int max) {
         this.pool.setMaxTotal(max);
     }
 
+    @Override
     public void setDefaultMaxPerRoute(final int max) {
         this.pool.setDefaultMaxPerRoute(max);
     }
 
+    @Override
     public void setMaxPerRoute(final HttpRoute route, final int max) {
         this.pool.setMaxPerRoute(route, max);
     }
 
+    @Override
     public int getMaxTotal() {
         return this.pool.getMaxTotal();
     }
 
+    @Override
     public int getDefaultMaxPerRoute() {
         return this.pool.getDefaultMaxPerRoute();
     }
 
+    @Override
     public int getMaxPerRoute(final HttpRoute route) {
         return this.pool.getMaxPerRoute(route);
     }
@@ -280,6 +295,7 @@ public class PoolingClientAsyncConnectio
             this.future = future;
         }
 
+        @Override
         public void completed(final HttpPoolEntry entry) {
             if (log.isDebugEnabled()) {
                 log.debug("Connection leased: " + format(entry) + formatStats(entry.getRoute()));
@@ -293,6 +309,7 @@ public class PoolingClientAsyncConnectio
             }
         }
 
+        @Override
         public void failed(final Exception ex) {
             if (log.isDebugEnabled()) {
                 log.debug("Connection request failed", ex);
@@ -300,6 +317,7 @@ public class PoolingClientAsyncConnectio
             this.future.failed(ex);
         }
 
+        @Override
         public void cancelled() {
             log.debug("Connection request cancelled");
             this.future.cancel(true);

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/SSLLayeringStrategy.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/SSLLayeringStrategy.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/SSLLayeringStrategy.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/SSLLayeringStrategy.java Fri Oct 10 19:48:55 2014
@@ -178,10 +178,12 @@ public class SSLLayeringStrategy impleme
         this(sslContext, new BrowserCompatHostnameVerifier());
     }
 
+    @Override
     public boolean isSecure() {
         return true;
     }
 
+    @Override
     public SSLIOSession layer(final IOSession iosession) {
         final SSLIOSession ssliosession = new SSLIOSession(
             iosession,
@@ -189,11 +191,13 @@ public class SSLLayeringStrategy impleme
             this.sslContext,
             new SSLSetupHandler() {
 
+                @Override
                 public void initalize(
                         final SSLEngine sslengine) throws SSLException {
                     initializeEngine(sslengine);
                 }
 
+                @Override
                 public void verify(
                         final IOSession iosession,
                         final SSLSession sslsession) throws SSLException {

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/TrustManagerDecorator.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/TrustManagerDecorator.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/TrustManagerDecorator.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java-deprecated/org/apache/http/nio/conn/ssl/TrustManagerDecorator.java Fri Oct 10 19:48:55 2014
@@ -45,11 +45,13 @@ class TrustManagerDecorator implements X
         this.trustStrategy = trustStrategy;
     }
 
+    @Override
     public void checkClientTrusted(
             final X509Certificate[] chain, final String authType) throws CertificateException {
         this.trustManager.checkClientTrusted(chain, authType);
     }
 
+    @Override
     public void checkServerTrusted(
             final X509Certificate[] chain, final String authType) throws CertificateException {
         if (!this.trustStrategy.isTrusted(chain, authType)) {
@@ -57,6 +59,7 @@ class TrustManagerDecorator implements X
         }
     }
 
+    @Override
     public X509Certificate[] getAcceptedIssuers() {
         return this.trustManager.getAcceptedIssuers();
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClient.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClient.java Fri Oct 10 19:48:55 2014
@@ -59,6 +59,7 @@ public abstract class CloseableHttpAsync
 
     public abstract void start();
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,
@@ -66,6 +67,7 @@ public abstract class CloseableHttpAsync
         return execute(requestProducer, responseConsumer, new BasicHttpContext(), callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpHost target, final HttpRequest request, final HttpContext context,
             final FutureCallback<HttpResponse> callback) {
@@ -75,18 +77,21 @@ public abstract class CloseableHttpAsync
                 context, callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpHost target, final HttpRequest request,
             final FutureCallback<HttpResponse> callback) {
         return execute(target, request, new BasicHttpContext(), callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpUriRequest request,
             final FutureCallback<HttpResponse> callback) {
         return execute(request, new BasicHttpContext(), callback);
     }
 
+    @Override
     public Future<HttpResponse> execute(
             final HttpUriRequest request,
             final HttpContext context,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClientBase.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClientBase.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClientBase.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/CloseableHttpAsyncClientBase.java Fri Oct 10 19:48:55 2014
@@ -94,6 +94,7 @@ abstract class CloseableHttpAsyncClientB
                 "I/O reactor status: %s", currentStatus);
     }
 
+    @Override
     public void close() {
         if (this.status.compareAndSet(Status.ACTIVE, Status.STOPPED)) {
             if (this.reactorThread != null) {

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultAsyncUserTokenHandler.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultAsyncUserTokenHandler.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultAsyncUserTokenHandler.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultAsyncUserTokenHandler.java Fri Oct 10 19:48:55 2014
@@ -60,6 +60,7 @@ public class DefaultAsyncUserTokenHandle
 
     public static final DefaultAsyncUserTokenHandler INSTANCE = new DefaultAsyncUserTokenHandler();
 
+    @Override
     public Object getUserToken(final HttpContext context) {
 
         final HttpClientContext clientContext = HttpClientContext.adapt(context);

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultClientExchangeHandlerImpl.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultClientExchangeHandlerImpl.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultClientExchangeHandlerImpl.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/DefaultClientExchangeHandlerImpl.java Fri Oct 10 19:48:55 2014
@@ -98,6 +98,7 @@ class DefaultClientExchangeHandlerImpl<T
         this.managedConn = new AtomicReference<NHttpClientConnection>(null);
     }
 
+    @Override
     public void close() {
         if (this.closed.getAndSet(true)) {
             return;
@@ -126,28 +127,34 @@ class DefaultClientExchangeHandlerImpl<T
         requestConnection();
     }
 
+    @Override
     public boolean isDone() {
         return this.completed.get();
     }
 
+    @Override
     public HttpRequest generateRequest() throws IOException, HttpException {
         return this.exec.generateRequest(this.state, this);
     }
 
+    @Override
     public void produceContent(
             final ContentEncoder encoder, final IOControl ioctrl) throws IOException {
         this.exec.produceContent(this.state, encoder, ioctrl);
     }
 
+    @Override
     public void requestCompleted() {
         this.exec.requestCompleted(this.state);
     }
 
+    @Override
     public void responseReceived(
             final HttpResponse response) throws IOException, HttpException {
         this.exec.responseReceived(this.state, response);
     }
 
+    @Override
     public void consumeContent(
             final ContentDecoder decoder, final IOControl ioctrl) throws IOException {
         this.exec.consumeContent(this.state, decoder, ioctrl);
@@ -163,6 +170,7 @@ class DefaultClientExchangeHandlerImpl<T
         }
     }
 
+    @Override
     public void responseCompleted() throws IOException, HttpException {
         this.exec.responseCompleted(this.state, this);
 
@@ -194,6 +202,7 @@ class DefaultClientExchangeHandlerImpl<T
         }
     }
 
+    @Override
     public void inputTerminated() {
         if (!this.completed.get()) {
             requestConnection();
@@ -202,6 +211,7 @@ class DefaultClientExchangeHandlerImpl<T
         }
     }
 
+    @Override
     public void releaseConnection() {
         final NHttpClientConnection localConn = this.managedConn.getAndSet(null);
         if (localConn != null) {
@@ -230,6 +240,7 @@ class DefaultClientExchangeHandlerImpl<T
         }
     }
 
+    @Override
     public void abortConnection() {
         discardConnection();
     }
@@ -252,6 +263,7 @@ class DefaultClientExchangeHandlerImpl<T
         }
     }
 
+    @Override
     public void failed(final Exception ex) {
         try {
             this.requestProducer.failed(ex);
@@ -265,6 +277,7 @@ class DefaultClientExchangeHandlerImpl<T
         }
     }
 
+    @Override
     public boolean cancel() {
         if (this.log.isDebugEnabled()) {
             this.log.debug("[exchange: " + this.state.getId() + "] Cancelled");
@@ -355,14 +368,17 @@ class DefaultClientExchangeHandlerImpl<T
                 TimeUnit.MILLISECONDS,
                 new FutureCallback<NHttpClientConnection>() {
 
+                    @Override
                     public void completed(final NHttpClientConnection managedConn) {
                         connectionAllocated(managedConn);
                     }
 
+                    @Override
                     public void failed(final Exception ex) {
                         connectionRequestFailed(ex);
                     }
 
+                    @Override
                     public void cancelled() {
                         connectionRequestCancelled();
                     }
@@ -370,6 +386,7 @@ class DefaultClientExchangeHandlerImpl<T
                 });
     }
 
+    @Override
     public NHttpClientConnection getConnection() {
         return this.managedConn.get();
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalHttpAsyncClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalHttpAsyncClient.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalHttpAsyncClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalHttpAsyncClient.java Fri Oct 10 19:48:55 2014
@@ -104,6 +104,7 @@ class InternalHttpAsyncClient extends Cl
         }
     }
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalIOReactorExceptionHandler.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalIOReactorExceptionHandler.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalIOReactorExceptionHandler.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/InternalIOReactorExceptionHandler.java Fri Oct 10 19:48:55 2014
@@ -40,11 +40,13 @@ class InternalIOReactorExceptionHandler 
         this.log = log;
     }
 
+    @Override
     public boolean handle(final IOException ex) {
         this.log.error("Fatal I/O error", ex);
         return false;
     }
 
+    @Override
     public boolean handle(final RuntimeException ex) {
         this.log.error("Fatal runtime error", ex);
         return false;

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java Fri Oct 10 19:48:55 2014
@@ -125,6 +125,7 @@ class MainClientExec implements Internal
         this.authenticator = new HttpAuthenticator(log);
     }
 
+    @Override
     public void prepare(
             final InternalState state,
             final HttpHost target,
@@ -156,6 +157,7 @@ class MainClientExec implements Internal
         prepareRequest(state);
     }
 
+    @Override
     public HttpRequest generateRequest(
             final InternalState state,
             final InternalConnManager connManager) throws IOException, HttpException {
@@ -271,6 +273,7 @@ class MainClientExec implements Internal
         return currentRequest;
     }
 
+    @Override
     public void produceContent(
             final InternalState state,
             final ContentEncoder encoder,
@@ -286,6 +289,7 @@ class MainClientExec implements Internal
         }
     }
 
+    @Override
     public void requestCompleted(final InternalState state) {
         if (this.log.isDebugEnabled()) {
             this.log.debug("[exchange: " + state.getId() + "] Request completed");
@@ -295,6 +299,7 @@ class MainClientExec implements Internal
         requestProducer.requestCompleted(localContext);
     }
 
+    @Override
     public void responseReceived(
             final InternalState state,
             final HttpResponse response) throws IOException, HttpException {
@@ -333,6 +338,7 @@ class MainClientExec implements Internal
         }
     }
 
+    @Override
     public void consumeContent(
             final InternalState state,
             final ContentDecoder decoder,
@@ -350,6 +356,7 @@ class MainClientExec implements Internal
         }
     }
 
+    @Override
     public void responseCompleted(
             final InternalState state,
             final InternalConnManager connManager) throws IOException, HttpException {

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalClientExec.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalClientExec.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalClientExec.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalClientExec.java Fri Oct 10 19:48:55 2014
@@ -73,6 +73,7 @@ class MinimalClientExec implements Inter
         this.keepaliveStrategy = keepaliveStrategy;
     }
 
+    @Override
     public void prepare(
             final InternalState state,
             final HttpHost target,
@@ -102,6 +103,7 @@ class MinimalClientExec implements Inter
         this.httpProcessor.process(request, localContext);
     }
 
+    @Override
     public HttpRequest generateRequest(
             final InternalState state,
             final InternalConnManager connManager) throws IOException, HttpException {
@@ -120,6 +122,7 @@ class MinimalClientExec implements Inter
         return state.getCurrentRequest();
     }
 
+    @Override
     public void produceContent(
             final InternalState state,
             final ContentEncoder encoder,
@@ -135,6 +138,7 @@ class MinimalClientExec implements Inter
         }
     }
 
+    @Override
     public void requestCompleted(final InternalState state) {
         if (this.log.isDebugEnabled()) {
             this.log.debug("[exchange: " + state.getId() + "] Request completed");
@@ -144,6 +148,7 @@ class MinimalClientExec implements Inter
         requestProducer.requestCompleted(localContext);
     }
 
+    @Override
     public void responseReceived(
             final InternalState state,
             final HttpResponse response) throws IOException, HttpException {
@@ -159,6 +164,7 @@ class MinimalClientExec implements Inter
         responseConsumer.responseReceived(response);
     }
 
+    @Override
     public void consumeContent(
             final InternalState state,
             final ContentDecoder decoder,
@@ -170,6 +176,7 @@ class MinimalClientExec implements Inter
         responseConsumer.consumeContent(decoder, ioctrl);
     }
 
+    @Override
     public void responseCompleted(
             final InternalState state,
             final InternalConnManager connManager) throws IOException, HttpException {

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalHttpAsyncClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalHttpAsyncClient.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalHttpAsyncClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MinimalHttpAsyncClient.java Fri Oct 10 19:48:55 2014
@@ -81,6 +81,7 @@ class MinimalHttpAsyncClient extends Clo
         this(connmgr, Executors.defaultThreadFactory(), new LoggingAsyncRequestExecutor());
     }
 
+    @Override
     public <T> Future<T> execute(
             final HttpAsyncRequestProducer requestProducer,
             final HttpAsyncResponseConsumer<T> responseConsumer,

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java Fri Oct 10 19:48:55 2014
@@ -54,18 +54,22 @@ class LoggingIOSession implements IOSess
         this.wirelog = new Wire(wirelog, this.id);
     }
 
+    @Override
     public ByteChannel channel() {
         return this.channel;
     }
 
+    @Override
     public SocketAddress getLocalAddress() {
         return this.session.getLocalAddress();
     }
 
+    @Override
     public SocketAddress getRemoteAddress() {
         return this.session.getRemoteAddress();
     }
 
+    @Override
     public int getEventMask() {
         return this.session.getEventMask();
     }
@@ -89,6 +93,7 @@ class LoggingIOSession implements IOSess
         return buffer.toString();
     }
 
+    @Override
     public void setEventMask(final int ops) {
         this.session.setEventMask(ops);
         if (this.log.isDebugEnabled()) {
@@ -96,6 +101,7 @@ class LoggingIOSession implements IOSess
         }
     }
 
+    @Override
     public void setEvent(final int op) {
         this.session.setEvent(op);
         if (this.log.isDebugEnabled()) {
@@ -103,6 +109,7 @@ class LoggingIOSession implements IOSess
         }
     }
 
+    @Override
     public void clearEvent(final int op) {
         this.session.clearEvent(op);
         if (this.log.isDebugEnabled()) {
@@ -110,6 +117,7 @@ class LoggingIOSession implements IOSess
         }
     }
 
+    @Override
     public void close() {
         if (this.log.isDebugEnabled()) {
             this.log.debug(this.id + " " + this.session + ": Close");
@@ -117,14 +125,17 @@ class LoggingIOSession implements IOSess
         this.session.close();
     }
 
+    @Override
     public int getStatus() {
         return this.session.getStatus();
     }
 
+    @Override
     public boolean isClosed() {
         return this.session.isClosed();
     }
 
+    @Override
     public void shutdown() {
         if (this.log.isDebugEnabled()) {
             this.log.debug(this.id + " " + this.session + ": Shutdown");
@@ -132,10 +143,12 @@ class LoggingIOSession implements IOSess
         this.session.shutdown();
     }
 
+    @Override
     public int getSocketTimeout() {
         return this.session.getSocketTimeout();
     }
 
+    @Override
     public void setSocketTimeout(final int timeout) {
         if (this.log.isDebugEnabled()) {
             this.log.debug(this.id + " " + this.session + ": Set timeout " + timeout);
@@ -143,22 +156,27 @@ class LoggingIOSession implements IOSess
         this.session.setSocketTimeout(timeout);
     }
 
+    @Override
     public void setBufferStatus(final SessionBufferStatus status) {
         this.session.setBufferStatus(status);
     }
 
+    @Override
     public boolean hasBufferedInput() {
         return this.session.hasBufferedInput();
     }
 
+    @Override
     public boolean hasBufferedOutput() {
         return this.session.hasBufferedOutput();
     }
 
+    @Override
     public Object getAttribute(final String name) {
         return this.session.getAttribute(name);
     }
 
+    @Override
     public void setAttribute(final String name, final Object obj) {
         if (this.log.isDebugEnabled()) {
             this.log.debug(this.id + " " + this.session + ": Set attribute " + name);
@@ -166,6 +184,7 @@ class LoggingIOSession implements IOSess
         this.session.setAttribute(name, obj);
     }
 
+    @Override
     public Object removeAttribute(final String name) {
         if (this.log.isDebugEnabled()) {
             this.log.debug(this.id + " " + this.session + ": Remove attribute " + name);
@@ -180,6 +199,7 @@ class LoggingIOSession implements IOSess
 
     class LoggingByteChannel implements ByteChannel {
 
+        @Override
         public int read(final ByteBuffer dst) throws IOException {
             final int bytesRead = session.channel().read(dst);
             if (log.isDebugEnabled()) {
@@ -195,6 +215,7 @@ class LoggingIOSession implements IOSess
             return bytesRead;
         }
 
+        @Override
         public int write(final ByteBuffer src) throws IOException {
             final int byteWritten = session.channel().write(src);
             if (log.isDebugEnabled()) {
@@ -210,6 +231,7 @@ class LoggingIOSession implements IOSess
             return byteWritten;
         }
 
+        @Override
         public void close() throws IOException {
             if (log.isDebugEnabled()) {
                 log.debug(id + " " + session + ": Channel close");
@@ -217,6 +239,7 @@ class LoggingIOSession implements IOSess
             session.channel().close();
         }
 
+        @Override
         public boolean isOpen() {
             return session.channel().isOpen();
         }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionFactory.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionFactory.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionFactory.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionFactory.java Fri Oct 10 19:48:55 2014
@@ -83,6 +83,7 @@ public class ManagedNHttpClientConnectio
         this(null, null, null);
     }
 
+    @Override
     public ManagedNHttpClientConnection create(
             final IOSession iosession, final ConnectionConfig config) {
         final String id = "http-outgoing-" + Long.toString(COUNTER.getAndIncrement());

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionImpl.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionImpl.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionImpl.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/ManagedNHttpClientConnectionImpl.java Fri Oct 10 19:48:55 2014
@@ -100,10 +100,12 @@ class ManagedNHttpClientConnectionImpl
         }
     }
 
+    @Override
     public IOSession getIOSession() {
         return this.original;
     }
 
+    @Override
     public SSLSession getSSLSession() {
         if (this.original instanceof SSLIOSession) {
             return ((SSLIOSession) this.original).getSSLSession();
@@ -112,6 +114,7 @@ class ManagedNHttpClientConnectionImpl
         }
     }
 
+    @Override
     public String getId() {
         return this.id;
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/PoolingNHttpClientConnectionManager.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/PoolingNHttpClientConnectionManager.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/PoolingNHttpClientConnectionManager.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/PoolingNHttpClientConnectionManager.java Fri Oct 10 19:48:55 2014
@@ -186,6 +186,7 @@ public class PoolingNHttpClientConnectio
         }
     }
 
+    @Override
     public void execute(final IOEventDispatch eventDispatch) throws IOException {
         this.ioreactor.execute(eventDispatch);
     }
@@ -196,6 +197,7 @@ public class PoolingNHttpClientConnectio
         this.log.debug("Connection manager shut down");
     }
 
+    @Override
     public void shutdown() throws IOException {
         this.log.debug("Connection manager is shutting down");
         this.pool.shutdown(2000);
@@ -234,6 +236,7 @@ public class PoolingNHttpClientConnectio
         return buf.toString();
     }
 
+    @Override
     public Future<NHttpClientConnection> requestConnection(
             final HttpRoute route,
             final Object state,
@@ -265,6 +268,7 @@ public class PoolingNHttpClientConnectio
         return future;
     }
 
+    @Override
     public void releaseConnection(
             final NHttpClientConnection managedConn,
             final Object state,
@@ -313,6 +317,7 @@ public class PoolingNHttpClientConnectio
         return reg;
     }
 
+    @Override
     public void startRoute(
             final NHttpClientConnection managedConn,
             final HttpRoute route,
@@ -341,6 +346,7 @@ public class PoolingNHttpClientConnectio
         }
     }
 
+    @Override
     public void upgrade(
             final NHttpClientConnection managedConn,
             final HttpRoute route,
@@ -366,6 +372,7 @@ public class PoolingNHttpClientConnectio
         }
     }
 
+    @Override
     public void routeComplete(
             final NHttpClientConnection managedConn,
             final HttpRoute route,
@@ -378,6 +385,7 @@ public class PoolingNHttpClientConnectio
         }
     }
 
+    @Override
     public boolean isRouteComplete(
             final NHttpClientConnection managedConn) {
         Args.notNull(managedConn, "Managed connection");
@@ -387,6 +395,7 @@ public class PoolingNHttpClientConnectio
         }
     }
 
+    @Override
     public void closeIdleConnections(final long idleTimeout, final TimeUnit tunit) {
         if (this.log.isDebugEnabled()) {
             this.log.debug("Closing connections idle longer than " + idleTimeout + " " + tunit);
@@ -394,39 +403,48 @@ public class PoolingNHttpClientConnectio
         this.pool.closeIdle(idleTimeout, tunit);
     }
 
+    @Override
     public void closeExpiredConnections() {
         log.debug("Closing expired connections");
         this.pool.closeExpired();
     }
 
+    @Override
     public int getMaxTotal() {
         return this.pool.getMaxTotal();
     }
 
+    @Override
     public void setMaxTotal(final int max) {
         this.pool.setMaxTotal(max);
     }
 
+    @Override
     public int getDefaultMaxPerRoute() {
         return this.pool.getDefaultMaxPerRoute();
     }
 
+    @Override
     public void setDefaultMaxPerRoute(final int max) {
         this.pool.setDefaultMaxPerRoute(max);
     }
 
+    @Override
     public int getMaxPerRoute(final HttpRoute route) {
         return this.pool.getMaxPerRoute(route);
     }
 
+    @Override
     public void setMaxPerRoute(final HttpRoute route, final int max) {
         this.pool.setMaxPerRoute(route, max);
     }
 
+    @Override
     public PoolStats getTotalStats() {
         return this.pool.getTotalStats();
     }
 
+    @Override
     public PoolStats getStats(final HttpRoute route) {
         return this.pool.getStats(route);
     }
@@ -464,6 +482,7 @@ public class PoolingNHttpClientConnectio
             this.future = future;
         }
 
+        @Override
         public void completed(final CPoolEntry entry) {
             Asserts.check(entry.getConnection() != null, "Pool entry with no connection");
             if (log.isDebugEnabled()) {
@@ -475,6 +494,7 @@ public class PoolingNHttpClientConnectio
             }
         }
 
+        @Override
         public void failed(final Exception ex) {
             if (log.isDebugEnabled()) {
                 log.debug("Connection request failed", ex);
@@ -482,6 +502,7 @@ public class PoolingNHttpClientConnectio
             this.future.failed(ex);
         }
 
+        @Override
         public void cancelled() {
             log.debug("Connection request cancelled");
             this.future.cancel(true);
@@ -531,6 +552,7 @@ public class PoolingNHttpClientConnectio
                 ManagedNHttpClientConnectionFactory.INSTANCE;
         }
 
+        @Override
         public ManagedNHttpClientConnection create(
                 final HttpRoute route, final IOSession iosession) throws IOException {
             ConnectionConfig config = null;
@@ -568,10 +590,12 @@ public class PoolingNHttpClientConnectio
                     SystemDefaultDnsResolver.INSTANCE;
         }
 
+        @Override
         public SocketAddress resolveLocalAddress(final HttpRoute route) throws IOException {
             return route.getLocalAddress() != null ? new InetSocketAddress(route.getLocalAddress(), 0) : null;
         }
 
+        @Override
         public SocketAddress resolveRemoteAddress(final HttpRoute route) throws IOException {
             final HttpHost host;
             if (route.getProxyHost() != null) {

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/client/methods/BaseZeroCopyRequestProducer.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/client/methods/BaseZeroCopyRequestProducer.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/client/methods/BaseZeroCopyRequestProducer.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/client/methods/BaseZeroCopyRequestProducer.java Fri Oct 10 19:48:55 2014
@@ -80,6 +80,7 @@ abstract class BaseZeroCopyRequestProduc
 
     protected abstract HttpEntityEnclosingRequest createRequest(final URI requestURI, final HttpEntity entity);
 
+    @Override
     public HttpRequest generateRequest() throws IOException, HttpException {
         final BasicHttpEntity entity = new BasicHttpEntity();
         entity.setChunked(false);
@@ -90,10 +91,12 @@ abstract class BaseZeroCopyRequestProduc
         return createRequest(this.requestURI, entity);
     }
 
+    @Override
     public synchronized HttpHost getTarget() {
         return URIUtils.extractHost(this.requestURI);
     }
 
+    @Override
     public synchronized void produceContent(
             final ContentEncoder encoder, final IOControl ioctrl) throws IOException {
         if (this.fileChannel == null) {
@@ -118,20 +121,25 @@ abstract class BaseZeroCopyRequestProduc
         }
     }
 
+    @Override
     public void requestCompleted(final HttpContext context) {
     }
 
+    @Override
     public void failed(final Exception ex) {
     }
 
+    @Override
     public boolean isRepeatable() {
         return true;
     }
 
+    @Override
     public synchronized void resetRequest() throws IOException {
         closeChannel();
     }
 
+    @Override
     public synchronized void close() throws IOException {
         try {
             this.accessfile.close();

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/NoopIOSessionStrategy.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/NoopIOSessionStrategy.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/NoopIOSessionStrategy.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/NoopIOSessionStrategy.java Fri Oct 10 19:48:55 2014
@@ -39,10 +39,12 @@ public class NoopIOSessionStrategy imple
 
     public static final NoopIOSessionStrategy INSTANCE = new NoopIOSessionStrategy();
 
+    @Override
     public IOSession upgrade(final HttpHost host, final IOSession iosession) {
         return iosession;
     }
 
+    @Override
     public boolean isLayeringRequired() {
         return false;
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/ssl/SSLIOSessionStrategy.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/ssl/SSLIOSessionStrategy.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/ssl/SSLIOSessionStrategy.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/nio/conn/ssl/SSLIOSessionStrategy.java Fri Oct 10 19:48:55 2014
@@ -155,6 +155,7 @@ public class SSLIOSessionStrategy implem
         this(sslcontext, null, null, getDefaultHostnameVerifier());
     }
 
+    @Override
     public SSLIOSession upgrade(final HttpHost host, final IOSession iosession) throws IOException {
         Asserts.check(!(iosession instanceof SSLIOSession), "I/O session is already upgraded to TLS/SSL");
         final SSLIOSession ssliosession = new SSLIOSession(
@@ -163,6 +164,7 @@ public class SSLIOSessionStrategy implem
             this.sslContext,
             new SSLSetupHandler() {
 
+                @Override
                 public void initalize(
                         final SSLEngine sslengine) throws SSLException {
                     if (supportedProtocols != null) {
@@ -174,6 +176,7 @@ public class SSLIOSessionStrategy implem
                     initializeEngine(sslengine);
                 }
 
+                @Override
                 public void verify(
                         final IOSession iosession,
                         final SSLSession sslsession) throws SSLException {
@@ -196,6 +199,7 @@ public class SSLIOSessionStrategy implem
         this.hostnameVerifier.verify(host.getHostName(), sslsession);
     }
 
+    @Override
     public boolean isLayeringRequired() {
         return true;
     }

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/EchoHandler.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/EchoHandler.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/EchoHandler.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/EchoHandler.java Fri Oct 10 19:48:55 2014
@@ -60,6 +60,7 @@ public class EchoHandler
      * @throws HttpException    in case of a problem
      * @throws IOException      in case of an IO problem
      */
+    @Override
     public void handle(final HttpRequest request,
                        final HttpResponse response,
                        final HttpContext context)

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RandomHandler.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RandomHandler.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RandomHandler.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RandomHandler.java Fri Oct 10 19:48:55 2014
@@ -68,6 +68,7 @@ public class RandomHandler implements Ht
      * @throws HttpException    in case of a problem
      * @throws IOException      in case of an IO problem
      */
+    @Override
     public void handle(final HttpRequest request,
                        final HttpResponse response,
                        final HttpContext context)

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RequestBasicAuth.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RequestBasicAuth.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RequestBasicAuth.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/RequestBasicAuth.java Fri Oct 10 19:48:55 2014
@@ -43,6 +43,7 @@ public class RequestBasicAuth implements
         this.authTokenExtractor = new BasicAuthTokenExtractor();
     }
 
+    @Override
     public void process(
             final HttpRequest request,
             final HttpContext context) throws HttpException, IOException {

Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/ResponseBasicUnauthorized.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/ResponseBasicUnauthorized.java?rev=1630965&r1=1630964&r2=1630965&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/ResponseBasicUnauthorized.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/test/java/org/apache/http/localserver/ResponseBasicUnauthorized.java Fri Oct 10 19:48:55 2014
@@ -38,6 +38,7 @@ import org.apache.http.protocol.HttpCont
 
 public class ResponseBasicUnauthorized implements HttpResponseInterceptor {
 
+    @Override
     public void process(
             final HttpResponse response,
             final HttpContext context) throws HttpException, IOException {



Mime
View raw message