org.mortbay.jetty.Request.setHandled()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(11.5k)|赞(0)|评价(0)|浏览(116)

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

Request.setHandled介绍

暂无

代码示例

代码示例来源:origin: pentaho/pentaho-kettle

public void handle( String target, HttpServletRequest request, HttpServletResponse response, int dispatch )
   throws IOException, ServletException {
  if ( target.contains( "/Callback" ) ) {
   CustomLocalServerReceiver.this.error = request.getParameter( "error" );
   if ( CustomLocalServerReceiver.this.code == null ) {
    CustomLocalServerReceiver.this.code = request.getParameter( "code" );
   }
   if ( CustomLocalServerReceiver.this.url != null && CustomLocalServerReceiver.this.error != null
     && CustomLocalServerReceiver.this.error.equals( "access_denied" ) ) {
    response.sendRedirect( CustomLocalServerReceiver.this.url );
   } else {
    super.handle( target, request, response, dispatch );
   }
   ( (Request) request ).setHandled( true );
  }
 }
}

代码示例来源:origin: twitter/ambrose

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

代码示例来源:origin: Netflix/eureka

private void sendOkResponseWithContent(Request request, HttpServletResponse response, String content)
      throws IOException {
    response.setContentType("application/json; charset=UTF-8");
    response.setStatus(HttpServletResponse.SC_OK);
    response.getOutputStream().write(content.getBytes("UTF-8"));
    response.getOutputStream().flush();
    request.setHandled(true);
    System.out.println("Eureka resource mock, sent response for request path: " + request.getPathInfo() +
        " with content" + content);
  }
}

代码示例来源:origin: Netflix/eureka

protected void sendOkResponseWithContent(Request request, HttpServletResponse response, Applications apps)
    throws IOException {
  String content = XmlXStream.getInstance().toXML(apps);
  response.setContentType("application/xml");
  response.setStatus(HttpServletResponse.SC_OK);
  response.getWriter().println(content);
  response.getWriter().flush();
  request.setHandled(true);
  System.out.println("Eureka port: " + port + ". " + System.currentTimeMillis() +
      ". Eureka resource mock, sent response for request path: " + request.getPathInfo() +
      ", apps count: " + apps.getRegisteredApplications().size());
}

代码示例来源:origin: org.motechproject/motech-testing-utils

@Override
protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  requests.put(request.getContextPath(), collectRequestInfo(request));
  response.setStatus(HttpServletResponse.SC_OK);
  response.getWriter().write(OK);
  Request baseRequest = (Request) request;
  baseRequest.setHandled(true);
}

代码示例来源:origin: ch.cern.hadoop/hadoop-sls

/**
 * package metrics information in a json and return
 * @param request http request
 * @param response http response
 * @throws java.io.IOException
 */
private void printJsonMetrics(HttpServletRequest request,
               HttpServletResponse response)
    throws IOException {
 response.setContentType("text/json");
 response.setStatus(HttpServletResponse.SC_OK);
 response.getWriter().println(generateRealTimeTrackingMetrics());
 ((Request) request).setHandled(true);
}

代码示例来源:origin: org.mortbay.jetty/jetty-embedded

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch) throws IOException, ServletException
  {
    Request base_request = (request instanceof Request) ? (Request)request:HttpConnection.getCurrentConnection().getRequest();
    base_request.setHandled(true);
    
    response.setContentType("text/html");
    response.setStatus(HttpServletResponse.SC_OK);
    response.getWriter().println("<h1>Hello OneHandler</h1>");
  }
}

代码示例来源:origin: org.mortbay.jetty/jetty-embedded

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch) throws IOException, ServletException
  {
    Request base_request = (request instanceof Request) ? (Request)request:HttpConnection.getCurrentConnection().getRequest();
    base_request.setHandled(true);
    response.setStatus(HttpServletResponse.SC_OK);
    response.setContentType("text/html");
    response.getWriter().println("<h1>Hello OneContext "+hello+"</h1>");
  }
}

代码示例来源:origin: org.mortbay.jetty/jetty-embedded

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch) throws IOException, ServletException
  {
    Request base_request = (request instanceof Request) ? (Request)request:HttpConnection.getCurrentConnection().getRequest();
    base_request.setHandled(true);
    response.setContentType("text/html");
    response.setStatus(HttpServletResponse.SC_OK);
    response.getWriter().println("<h1>Hello ManyHandler</h1>");
  }
}

代码示例来源:origin: org.mortbay.jetty/jetty-embedded

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch) throws IOException, ServletException
  {
    Request base_request = (request instanceof Request) ? (Request)request:HttpConnection.getCurrentConnection().getRequest();
    base_request.setHandled(true);
    
    response.setStatus(HttpServletResponse.SC_OK);
    response.setContentType("text/html");
    response.getWriter().println("<h1>Hello OneContext</h1>");
  }
}

代码示例来源:origin: aseldawy/spatialhadoop2

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch)
    throws IOException, ServletException {
  // Bypass cross-site scripting (XSS)
  response.addHeader("Access-Control-Allow-Origin", "*");
  response.addHeader("Access-Control-Allow-Credentials", "true");
  ((Request) request).setHandled(true);
  try {
    if (target.startsWith("/dynamic/showImage.cgi")) {
      displayImage(target, response);
    } else {
      LOG.info("Received request: '"+request.getRequestURL()+"'");
      tryToLoadStaticResource(target, response);
    }
  } catch (Exception e) {
    e.printStackTrace();
    //reportError(response, "Error placing the request", e);
  }
}

代码示例来源:origin: jpotts/alfresco-api-java-examples

@Override
public void handle(
  String target, HttpServletRequest request, HttpServletResponse response, int dispatch)
  throws IOException {
 if (!CALLBACK_PATH.equals(target)) {
  return;
 }
 writeLandingHtml(response);
 response.flushBuffer();
 ((Request) request).setHandled(true);
 String error = request.getParameter("error");
 if (error != null) {
  System.out.println("Authorization failed. Error=" + error);
  System.out.println("Quitting.");
  System.exit(1);
 }
 code = request.getParameter("code");
 synchronized (LocalServerReceiver.this) {
  LocalServerReceiver.this.notify();
 }
}

代码示例来源:origin: jpotts/alfresco-api-java-examples

@Override
public void handle(
  String target, HttpServletRequest request, HttpServletResponse response, int dispatch)
  throws IOException {
 if (!CALLBACK_PATH.equals(target)) {
  return;
 }
 writeLandingHtml(response);
 response.flushBuffer();
 ((Request) request).setHandled(true);
 String error = request.getParameter("error");
 if (error != null) {
  System.out.println("Authorization failed. Error=" + error);
  System.out.println("Quitting.");
  System.exit(1);
 }
 code = request.getParameter("code");
 synchronized (LocalServerReceiver.this) {
  LocalServerReceiver.this.notify();
 }
}

代码示例来源:origin: org.mortbay.jetty/com.springsource.org.mortbay.jetty.server

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch) throws IOException, ServletException
{
  if (_newContextURL==null)
    return;
  
  Request base_request=(request instanceof Request)?(Request)request:HttpConnection.getCurrentConnection().getRequest();
  
  String url = _newContextURL;
  if (!_discardPathInfo && request.getPathInfo()!=null)
    url=URIUtil.addPaths(url, request.getPathInfo());
  if (!_discardQuery && request.getQueryString()!=null)
    url+="?"+request.getQueryString();
  
  response.sendRedirect(url);
  if (_permanent)
    response.setStatus(HttpServletResponse.SC_MOVED_PERMANENTLY);
  
  base_request.setHandled(true);
}

代码示例来源:origin: aseldawy/spatialhadoop2

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch)
    throws IOException, ServletException {
  // Bypass cross-site scripting (XSS)
  response.addHeader("Access-Control-Allow-Origin", "*");
  response.addHeader("Access-Control-Allow-Credentials", "true");
  ((Request) request).setHandled(true);
  try {
    if (target.startsWith("/dynamic/showImage.cgi")) {
      displayImage(target, response);
    } else {
      LOG.info("Received request: '"+request.getRequestURL()+"'");
      tryToLoadStaticResource(target, response);
    }
  } catch (Exception e) {
    e.printStackTrace();
    //reportError(response, "Error placing the request", e);
  }
}

代码示例来源:origin: org.apache.geronimo.ext.openejb/openejb-http

public void handle(String target, HttpServletRequest req, HttpServletResponse res, int dispatch) throws IOException, ServletException {
    try {
      ((Request) req).setHandled(true);
      HttpRequest httpRequest = new ServletRequestAdapter(req, res, servletContext);
      HttpResponse httpResponse = new ServletResponseAdapter(res);
      JettyHttpServer.this.listener.onMessage(httpRequest, httpResponse);
    } catch (IOException e) {
      throw e;
    } catch (ServletException e) {
      throw e;
    } catch (Exception e) {
      throw new ServletException(e);
    }
  }
};

代码示例来源:origin: org.apache.tomee/openejb-http

@Override
  public void handle(final String target, final HttpServletRequest req, final HttpServletResponse res, final int dispatch) throws IOException, ServletException {
    try {
      ((Request) req).setHandled(true);
      final HttpRequest httpRequest = new ServletRequestAdapter(req, res, servletContext);
      final HttpResponse httpResponse = new ServletResponseAdapter(res);
      JettyHttpServer.this.listener.onMessage(httpRequest, httpResponse);
    } catch (IOException | ServletException e) {
      throw e;
    } catch (Exception e) {
      throw new ServletException(e);
    }
  }
};

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

@Override
  public void handle(final String target, final HttpServletRequest req, final HttpServletResponse res, final int dispatch) throws IOException, ServletException {
    try {
      ((Request) req).setHandled(true);
      final HttpRequest httpRequest = new ServletRequestAdapter(req, res, servletContext);
      final HttpResponse httpResponse = new ServletResponseAdapter(res);
      JettyHttpServer.this.listener.onMessage(httpRequest, httpResponse);
    } catch (final IOException e) {
      throw e;
    } catch (final ServletException e) {
      throw e;
    } catch (final Exception e) {
      throw new ServletException(e);
    }
  }
};

代码示例来源:origin: org.mortbay.jetty/com.springsource.org.mortbay.jetty.server

public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch) throws IOException
{
  HttpConnection.getCurrentConnection().getRequest().setHandled(true);
  response.setContentType(MimeTypes.TEXT_HTML_8859_1);
  ByteArrayISO8859Writer writer= new ByteArrayISO8859Writer(4096);
  HttpConnection connection = HttpConnection.getCurrentConnection();
  handleErrorPage(request, writer, connection.getResponse().getStatus(), connection.getResponse().getReason());
  writer.flush();
  response.setContentLength(writer.size());
  writer.writeTo(response.getOutputStream());
  writer.destroy();
}

代码示例来源:origin: org.restlet/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 response
 *            The Jetty response.
 * @param dispatch
 *            The Jetty dispatch mode.
 */
public void handle(String target, HttpServletRequest request,
    HttpServletResponse response, int dispatch) throws IOException,
    ServletException {
  final Request baseRequest = (request instanceof Request) ? (Request) request
      : HttpConnection.getCurrentConnection().getRequest();
  this.helper.handle(new JettyCall(this.helper.getHelped(),
      HttpConnection.getCurrentConnection()));
  baseRequest.setHandled(true);
}

相关文章