本文整理了Java中org.mortbay.jetty.Request.setHandled
方法的一些代码示例,展示了Request.setHandled
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Request.setHandled
方法的具体详情如下:
包路径:org.mortbay.jetty.Request
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!