Apache/httpcomponents-client
1
0
Fork 0
mirror of https://github.com/apache/httpcomponents-client.git synced 2025-02-28 13:49:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add missing '@Override' annotations.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk@1788708 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary D. Gregory 2017-03-26 02:35:13 +00:00
parent 0aff0348ad
commit 857bcfb04d
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
httpclient5/src/main/java/org/apache/hc/client5/http/impl/async/InternalHttpAsyncClient.java
View File

@ -316,6 +316,7 @@ void updateState() {
userTokenRef.set(userToken); userTokenRef.set(userToken);
} }
@Override
public void produceRequest( public void produceRequest(
final RequestChannel channel) throws HttpException, IOException { final RequestChannel channel) throws HttpException, IOException {
exchangeHandler.produceRequest(log.isDebugEnabled() ? new RequestChannel() { exchangeHandler.produceRequest(log.isDebugEnabled() ? new RequestChannel() {
@ -333,14 +334,17 @@ public void sendRequest(
} : channel); } : channel);
} }
@Override
public int available() { public int available() {
return exchangeHandler.available(); return exchangeHandler.available();
} }
@Override
public void produce(final DataStreamChannel channel) throws IOException { public void produce(final DataStreamChannel channel) throws IOException {
exchangeHandler.produce(channel); exchangeHandler.produce(channel);
} }
@Override
public void consumeResponse( public void consumeResponse(
final HttpResponse response, final HttpResponse response,
final EntityDetails entityDetails) throws HttpException, IOException { final EntityDetails entityDetails) throws HttpException, IOException {
@ -359,6 +363,7 @@ public void consumeResponse(
} }
} }
@Override
public void consumeInformation(final HttpResponse response) throws HttpException, IOException { public void consumeInformation(final HttpResponse response) throws HttpException, IOException {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": intermediate response " + new StatusLine(response)); log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": intermediate response " + new StatusLine(response));
@ -366,14 +371,17 @@ public void consumeInformation(final HttpResponse response) throws HttpException
exchangeHandler.consumeInformation(response); exchangeHandler.consumeInformation(response);
} }
@Override
public void updateCapacity(final CapacityChannel capacityChannel) throws IOException { public void updateCapacity(final CapacityChannel capacityChannel) throws IOException {
exchangeHandler.updateCapacity(capacityChannel); exchangeHandler.updateCapacity(capacityChannel);
} }
@Override
public int consume(final ByteBuffer src) throws IOException { public int consume(final ByteBuffer src) throws IOException {
return exchangeHandler.consume(src); return exchangeHandler.consume(src);
} }
@Override
public void streamEnd(final List<? extends Header> trailers) throws HttpException, IOException { public void streamEnd(final List<? extends Header> trailers) throws HttpException, IOException {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": completed"); log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": completed");
@ -382,6 +390,7 @@ public void streamEnd(final List<? extends Header> trailers) throws HttpExceptio
updateState(); updateState();
} }
@Override
public void failed(final Exception cause) { public void failed(final Exception cause) {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": failed", cause); log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": failed", cause);
@ -390,6 +399,7 @@ public void failed(final Exception cause) {
exchangeHandler.failed(cause); exchangeHandler.failed(cause);
} }
@Override
public void cancel() { public void cancel() {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": cancelled"); log.debug(ConnPoolSupport.getId(connectionEndpoint) + " exchange " + id + ": cancelled");
@ -398,6 +408,7 @@ public void cancel() {
exchangeHandler.cancel(); exchangeHandler.cancel();
} }
@Override
public void releaseResources() { public void releaseResources() {
exchangeHandler.releaseResources(); exchangeHandler.releaseResources();
} }