Java 类org.apache.http.nio.protocol.HttpAsyncRequestConsumer 实例源码

public HttpAsyncRequestConsumer<ProxyHttpExchange> processRequest(
        final HttpRequest request,
        final HttpContext context) {
    ProxyHttpExchange httpExchange = (ProxyHttpExchange) context.getAttribute("http-exchange");
    if (httpExchange == null) {
        httpExchange = new ProxyHttpExchange();
        context.setAttribute("http-exchange", httpExchange);
    }
    synchronized (httpExchange) {
        httpExchange.reset();
        String id = String.format("%08X", this.counter.getAndIncrement());
        httpExchange.setId(id);
        httpExchange.setTarget(this.target);
        return new ProxyRequestConsumer(httpExchange, this.executor, this.connPool);
    }
}

@Override
public HttpAsyncRequestConsumer<HttpRequest> processRequest( final HttpRequest httpRequest,
                                                             final HttpContext httpContext )
   throws HttpException, IOException {

   return new BasicAsyncRequestConsumer();
}

@Override
public HttpAsyncRequestConsumer<HttpRequest> processRequest( HttpRequest request,
    HttpContext context ) throws HttpException, IOException {
    return new BasicAsyncRequestConsumer();
}

@Override
public HttpAsyncRequestConsumer<HttpRequest> processRequest(final HttpRequest request, final HttpContext context) {
    // Buffer request content in memory for simplicity
    return new BasicAsyncRequestConsumer();
}

@Override
public HttpAsyncRequestConsumer<HttpRequest> processRequest(
        final HttpRequest request, final HttpContext context) {
    // Buffer request content in memory for simplicity
    return new BasicAsyncRequestConsumer();
}

@Override
public HttpAsyncRequestConsumer<HttpRequest> processRequest(final HttpRequest request, final HttpContext context) {
    // Buffer request content in memory for simplicity
    return new BasicAsyncRequestConsumer();
}

@Override
public HttpAsyncRequestConsumer<HttpRequest> processRequest(HttpRequest httpRequest, HttpContext httpContext) throws HttpException, IOException {
    // Buffer request content in memory for simplicity
    return new BasicAsyncRequestConsumer();
}