本文整理了Java中org.eclipse.jetty.client.api.Request.getContent方法的一些代码示例，展示了Request.getContent的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Request.getContent方法的具体详情如下：
包路径：org.eclipse.jetty.client.api.Request
类名称：Request
方法名：getContent

Request.getContent介绍

暂无

代码示例

代码示例来源：origin: org.apache.camel/camel-jetty9

protected void closeRequestContentSource() {
  tryClose(this.request.getContent());
}

代码示例来源：origin: org.eclipse.jetty.spdy/spdy-http-server

@Override
  public void onData(Stream clientStream, final DataInfo clientDataInfo)
  {
    if (LOG.isDebugEnabled())
      LOG.debug("received clientDataInfo: {} for stream: {}", clientDataInfo, clientStream);
    DeferredContentProvider contentProvider = (DeferredContentProvider)request.getContent();
    contentProvider.offer(clientDataInfo.asByteBuffer(true));
    if (clientDataInfo.isClose())
      contentProvider.close();
  }
};

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

public void send(HttpExchange exchange)
{
  if (!updateState(State.IDLE, State.BEGIN))
    throw new IllegalStateException();
  Request request = exchange.getRequest();
  Throwable cause = request.getAbortCause();
  if (cause != null)
  {
    exchange.abort(cause);
  }
  else
  {
    LOG.debug("Sending {}", request);
    RequestNotifier notifier = connection.getDestination().getRequestNotifier();
    notifier.notifyBegin(request);
    ContentProvider content = request.getContent();
    this.contentIterator = content == null ? Collections.<ByteBuffer>emptyIterator() : content.iterator();
    boolean updated = updateSendState(SendState.IDLE, SendState.EXECUTE);
    assert updated;
    // Setting the listener may trigger calls to onContent() by other
    // threads so we must set it only after the state has been updated
    if (content instanceof AsyncContentProvider)
      ((AsyncContentProvider)content).setListener(this);
    send();
  }
}

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

public void send(HttpExchange exchange)
{
  if (!updateState(State.IDLE, State.BEGIN))
    throw new IllegalStateException();
  Request request = exchange.getRequest();
  Throwable cause = request.getAbortCause();
  if (cause != null)
  {
    exchange.abort(cause);
  }
  else
  {
    LOG.debug("Sending {}", request);
    RequestNotifier notifier = connection.getDestination().getRequestNotifier();
    notifier.notifyBegin(request);
    ContentProvider content = request.getContent();
    this.contentIterator = content == null ? Collections.<ByteBuffer>emptyIterator() : content.iterator();
    boolean updated = updateSendState(SendState.IDLE, SendState.EXECUTE);
    assert updated;
    // Setting the listener may trigger calls to onContent() by other
    // threads so we must set it only after the state has been updated
    if (content instanceof AsyncContentProvider)
      ((AsyncContentProvider)content).setListener(this);
    send();
  }
}

代码示例来源：origin: org.eclipse.jetty/jetty-client

ContentProvider contentProvider = request.getContent();
HttpContent content = this.content = new HttpContent(contentProvider);

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

HttpVersion version = request.getVersion();
HttpFields headers = request.getHeaders();
ContentProvider content = request.getContent();
  if (method == HttpMethod.POST && request.getContent() != null)
    method = HttpMethod.GET;

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

HttpVersion version = request.getVersion();
HttpFields headers = request.getHeaders();
ContentProvider content = request.getContent();
  if (method == HttpMethod.POST && request.getContent() != null)
    method = HttpMethod.GET;

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

ContentProvider requestContent = request.getContent();
long contentLength = requestContent == null ? -1 : requestContent.getLength();
requestInfo = new HttpGenerator.RequestInfo(request.getVersion(), request.getHeaders(), contentLength, request.getMethod().asString(), request.getPath());

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

ContentProvider requestContent = request.getContent();
long contentLength = requestContent == null ? -1 : requestContent.getLength();
requestInfo = new HttpGenerator.RequestInfo(request.getVersion(), request.getHeaders(), contentLength, request.getMethod().asString(), request.getPath());

代码示例来源：origin: org.eclipse.jetty/jetty-client

ContentProvider content = request.getContent();
ProxyConfiguration.Proxy proxy = destination.getProxy();

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

protected Request copyRequest(Request oldRequest, URI newURI)
{
  Request newRequest = new HttpRequest(this, oldRequest.getConversationID(), newURI);
  newRequest.method(oldRequest.getMethod())
      .version(oldRequest.getVersion())
      .content(oldRequest.getContent());
  for (HttpField header : oldRequest.getHeaders())
  {
    // We have a new URI, so skip the host header if present
    if (HttpHeader.HOST == header.getHeader())
      continue;
    // Remove expectation headers
    if (HttpHeader.EXPECT == header.getHeader())
      continue;
    // Remove cookies
    if (HttpHeader.COOKIE == header.getHeader())
      continue;
    // Remove authorization headers
    if (HttpHeader.AUTHORIZATION == header.getHeader() ||
        HttpHeader.PROXY_AUTHORIZATION == header.getHeader())
      continue;
    newRequest.header(header.getName(), header.getValue());
  }
  return newRequest;
}

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

protected Request copyRequest(Request oldRequest, URI newURI)
{
  Request newRequest = new HttpRequest(this, oldRequest.getConversationID(), newURI);
  newRequest.method(oldRequest.getMethod())
      .version(oldRequest.getVersion())
      .content(oldRequest.getContent());
  for (HttpField header : oldRequest.getHeaders())
  {
    // We have a new URI, so skip the host header if present
    if (HttpHeader.HOST == header.getHeader())
      continue;
    // Remove expectation headers
    if (HttpHeader.EXPECT == header.getHeader())
      continue;
    // Remove cookies
    if (HttpHeader.COOKIE == header.getHeader())
      continue;
    // Remove authorization headers
    if (HttpHeader.AUTHORIZATION == header.getHeader() ||
        HttpHeader.PROXY_AUTHORIZATION == header.getHeader())
      continue;
    newRequest.header(header.getName(), header.getValue());
  }
  return newRequest;
}