Java 类org.apache.http.impl.client.RequestWrapper 实例源码

项目：FullRobolectricTestSample 文件：DefaultRequestDirector.java

protected void rewriteRequestURI(
    final RequestWrapper request,
    final HttpRoute route) throws ProtocolException {
  try {

    URI uri = request.getURI();
    if (route.getProxyHost() != null && !route.isTunnelled()) {
      // Make sure the request URI is absolute
      if (!uri.isAbsolute()) {
        HttpHost target = route.getTargetHost();
        uri = URIUtils.rewriteURI(uri, target);
        request.setURI(uri);
      }
    } else {
      // Make sure the request URI is relative
      if (uri.isAbsolute()) {
        uri = URIUtils.rewriteURI(uri, null);
        request.setURI(uri);
      }
    }

  } catch (URISyntaxException ex) {
    throw new ProtocolException("Invalid URI: " +
        request.getRequestLine().getUri(), ex);
  }
}

项目：YiBo 文件：LibRequestDirector.java

protected void rewriteRequestURI(
        final RequestWrapper request,
        final HttpRoute route) throws ProtocolException {
    try {

        URI uri = request.getURI();
        if (route.getProxyHost() != null && !route.isTunnelled()) {
            // Make sure the request URI is absolute
            if (!uri.isAbsolute()) {
                HttpHost target = route.getTargetHost();
                uri = URIUtils.rewriteURI(uri, target);
                request.setURI(uri);
            }
        } else {
            // Make sure the request URI is relative
            if (uri.isAbsolute()) {
                uri = URIUtils.rewriteURI(uri, null);
                request.setURI(uri);
            }
        }

    } catch (URISyntaxException ex) {
        throw new ProtocolException("Invalid URI: "
                + request.getRequestLine().getUri(), ex);
    }
}

项目：apigee-android-sdk 文件：ResponseProtocolCompliance.java

private void requestDidNotExpect100ContinueButResponseIsOne(
        HttpRequest request, HttpResponse response)
        throws ClientProtocolException {
    if (response.getStatusLine().getStatusCode() != HttpStatus.SC_CONTINUE) {
        return;
    }

    if (!requestWasWrapped(request)) {
        return;
    }

    ProtocolVersion originalProtocol = getOriginalRequestProtocol((RequestWrapper) request);

    if (originalProtocol.compareToVersion(HttpVersion.HTTP_1_1) >= 0) {
        return;
    }

    if (originalRequestDidNotExpectContinue((RequestWrapper) request)) {
        throw new ClientProtocolException(
                "The incoming request did not contain a "
                        + "100-continue header, but the response was a Status 100, continue.");

    }
}

项目：yibo-library 文件：YiBoRequestDirector.java

protected void rewriteRequestURI(
        final RequestWrapper request,
        final HttpRoute route) throws ProtocolException {
    try {

        URI uri = request.getURI();
        if (route.getProxyHost() != null && !route.isTunnelled()) {
            // Make sure the request URI is absolute
            if (!uri.isAbsolute()) {
                HttpHost target = route.getTargetHost();
                uri = URIUtils.rewriteURI(uri, target);
                request.setURI(uri);
            }
        } else {
            // Make sure the request URI is relative
            if (uri.isAbsolute()) {
                uri = URIUtils.rewriteURI(uri, null);
                request.setURI(uri);
            }
        }

    } catch (URISyntaxException ex) {
        throw new ProtocolException("Invalid URI: "
                + request.getRequestLine().getUri(), ex);
    }
}

项目：AkamaiOPEN-edgegrid-java 文件：ApacheHttpClientEdgeGridRequestSigner.java

@Override
protected void setHost(HttpRequest request, String host) {
    request.setHeader("Host", host);

    if (request instanceof HttpRequestWrapper) {
        setHost(((HttpRequestWrapper) request).getOriginal(), host);
    } else if (request instanceof RequestWrapper) {
        setHost(((RequestWrapper) request).getOriginal(), host);
    } else {
        URI oldUri = ((HttpRequestBase) request).getURI();
        try {
            URI newUri = replaceHost(oldUri, host);
            ((HttpRequestBase) request).setURI(newUri);
        } catch (URISyntaxException e) {
            throw new RuntimeException(e);
        }
    }
}

项目：FMTech 文件：PseudonymousCookieSource.java

private static RequestWrapper wrapRequest(HttpUriRequest paramHttpUriRequest)
  throws IOException
{
  // Byte code:
  //   0: aload_0
  //   1: instanceof 217
  //   4: ifeq +21 -> 25
  //   7: new 219   org/apache/http/impl/client/EntityEnclosingRequestWrapper
  //   10: dup
  //   11: aload_0
  //   12: checkcast 217    org/apache/http/HttpEntityEnclosingRequest
  //   15: invokespecial 222    org/apache/http/impl/client/EntityEnclosingRequestWrapper:<init>    (Lorg/apache/http/HttpEntityEnclosingRequest;)V
  //   18: astore_2
  //   19: aload_2
  //   20: invokevirtual 225    org/apache/http/impl/client/RequestWrapper:resetHeaders ()V
  //   23: aload_2
  //   24: areturn
  //   25: new 173  org/apache/http/impl/client/RequestWrapper
  //   28: dup
  //   29: aload_0
  //   30: invokespecial 228    org/apache/http/impl/client/RequestWrapper:<init>   (Lorg/apache/http/HttpRequest;)V
  //   33: astore_2
  //   34: goto -15 -> 19
  //   37: astore_1
  //   38: new 230  org/apache/http/client/ClientProtocolException
  //   41: dup
  //   42: aload_1
  //   43: invokespecial 233    org/apache/http/client/ClientProtocolException:<init>   (Ljava/lang/Throwable;)V
  //   46: athrow
  // Local variable table:
  //   start    length  slot    name    signature
  //   0    47  0   paramHttpUriRequest HttpUriRequest
  //   37   6   1   localProtocolException  org.apache.http.ProtocolException
  //   18   16  2   localObject Object
  // Exception table:
  //   from to  target  type
  //   0    19  37  org/apache/http/ProtocolException
  //   19   23  37  org/apache/http/ProtocolException
  //   25   34  37  org/apache/http/ProtocolException
}