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

HttpConnection.getCurrentConnection介绍

[英]Get the current connection that this thread is dispatched to. Note that a thread may be processing a request asynchronously and thus not be dispatched to the connection.
[中]获取此线程调度到的当前连接。请注意，线程可能正在异步处理请求，因此不会被分派到连接。

代码示例

代码示例来源：origin: neo4j/neo4j

public static JettyHttpConnection getCurrentJettyHttpConnection()
  {
    HttpConnection connection = HttpConnection.getCurrentConnection();
    return connection instanceof JettyHttpConnection ? (JettyHttpConnection) connection : null;
  }
}

代码示例来源：origin: org.neo4j.app/neo4j-server

public static JettyHttpConnection getCurrentJettyHttpConnection()
  {
    HttpConnection connection = HttpConnection.getCurrentConnection();
    return connection instanceof JettyHttpConnection ? (JettyHttpConnection) connection : null;
  }
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-rest-resources

private Request getJettyRequest() {
  return Optional.ofNullable(HttpConnection.getCurrentConnection())
      .map(HttpConnection::getHttpChannel)
      .map(HttpChannel::getRequest)
      .orElse(null);
}

代码示例来源：origin: apache/cxf

private Request getCurrentRequest() {
    try {
      HttpConnection con = HttpConnection.getCurrentConnection();

      HttpChannel channel = con.getHttpChannel();
      return channel.getRequest();
    } catch (Throwable t) {
      //
    }
    return null;
  }
}

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http-jetty

private Request getCurrentRequest() {
    try {
      HttpConnection con = HttpConnection.getCurrentConnection();

      HttpChannel channel = con.getHttpChannel();
      return channel.getRequest();
    } catch (Throwable t) {
      //
    }
    return null;
  }
}

代码示例来源：origin: org.mock-server/mockserver-jetty

@Override
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  if (HttpMethod.CONNECT.is(request.getMethod())) {
    logger.debug("CONNECT request for {}", request.getRequestURI());
    baseRequest.setHandled(true);
    ConnectContext connectContext = new ConnectContext(request, response, HttpConnection.getCurrentConnection().getEndPoint());
    try {
      SocketChannel channel = SocketChannel.open();
      channel.socket().setTcpNoDelay(true);
      channel.configureBlocking(false);
      channel.connect(new InetSocketAddress("127.0.0.1", securePort));
      selector.connect(channel, connectContext);
    } catch (IOException ioe) {
      connectContext.onConnectFailure(ioe);
    }
  } else {
    super.handle(target, baseRequest, request, response);
  }
}

代码示例来源：origin: com.google.gwt/gwt-codeserver

private static void setHandled(HttpServletRequest request) {
  Request baseRequest = (request instanceof Request) ? (Request) request :
    HttpConnection.getCurrentConnection().getHttpChannel().getRequest();
  baseRequest.setHandled(true);
 }
}

代码示例来源：origin: bazaarvoice/emodb

Request httpRequest = (request instanceof Request) ?
    (Request) request :
    HttpConnection.getCurrentConnection().getHttpChannel().getRequest();

代码示例来源：origin: org.restlet.jee/org.restlet.ext.jetty

/**
 * Handles a Jetty call by converting it to a Restlet call and giving it for
 * processing to the Restlet server.
 * 
 * @param target
 *            The target of the request, either a URI or a name.
 * @param request
 *            The Jetty request.
 * @param servletRequest
 *            The Servlet request.
 * @param servletResponse
 *            The Servlet response.
 */
public void handle(String target, Request arg1,
    HttpServletRequest servletRequest,
    HttpServletResponse servletResponse) throws IOException,
    ServletException {
  final Request baseRequest = (servletRequest instanceof Request) ? (Request) servletRequest
      : HttpConnection.getCurrentConnection().getRequest();
  this.helper.handle(new JettyCall(this.helper.getHelped(),
      HttpConnection.getCurrentConnection()));
  baseRequest.setHandled(true);
}

代码示例来源：origin: org.scalatra.socketio-java/socketio-core

HttpConnection httpConnection = HttpConnection.getCurrentConnection();
if (httpConnection != null) {
  EndPoint endPoint = httpConnection.getEndPoint();

代码示例来源：origin: tadglines/Socket.IO-Java

HttpConnection httpConnection = HttpConnection.getCurrentConnection();
if (httpConnection != null) {
  EndPoint endPoint = httpConnection.getEndPoint();

代码示例来源：origin: org.apache.servicemix/servicemix-http

public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  if (response.isCommitted() || HttpConnection.getCurrentConnection().getRequest().isHandled()) {
    return;

代码示例来源：origin: org.apache.servicemix/servicemix-cxf-bc

ServletException {
if (response.isCommitted()
    || HttpConnection.getCurrentConnection().getRequest()
        .isHandled()) {
  return;

代码示例来源：origin: bazaarvoice/emodb

/**
   * Certain aspects of the container, such as logging, need the authentication information to behave properly.
   * This method updates the request with the necessary objects to recognize the authenticated user.
   */
  private void setJettyAuthentication(Subject subject) {
    // In unit test environments there may not be a current connection.  If any nulls are encountered
    // then, by definition, there is no container to update.
    HttpConnection connection = HttpConnection.getCurrentConnection();
    if (connection == null) {
      return;
    }
    Request jettyRequest = connection.getHttpChannel().getRequest();
    if (jettyRequest == null) {
      return;
    }

    // This cast down is safe; subject is always created with this type of principal
    PrincipalWithRoles principal = (PrincipalWithRoles) subject.getPrincipal();
    UserIdentity identity = principal.toUserIdentity();

    jettyRequest.setAuthentication(new UserAuthentication(SecurityContext.BASIC_AUTH, identity));
  }
}

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

HttpConnection http = HttpConnection.getCurrentConnection();
EndPoint endp = http.getEndPoint();
Executor executor = http.getConnector().getExecutor();

代码示例来源：origin: jenkinsci/winstone