Package org.vertx.java.core.http

Examples of org.vertx.java.core.http.HttpServerResponse.end()


  }

  private void handlePlainText(HttpServerRequest req) {
    HttpServerResponse resp = req.response();
    setHeaders(resp, "text/plain", helloWorldContentLength);
    resp.end(helloWorldBuffer);
  }

  private void handleJson(HttpServerRequest req) {
    Buffer buff = new Buffer(Json.encode(Collections.singletonMap("message", "Hello, world!")));
    HttpServerResponse resp = req.response();
View Full Code Here


  private void handleJson(HttpServerRequest req) {
    Buffer buff = new Buffer(Json.encode(Collections.singletonMap("message", "Hello, world!")));
    HttpServerResponse resp = req.response();
    setHeaders(resp, "application/json", String.valueOf(buff.length()));
    resp.end(buff);
  }

  private void handleDbMongo(final HttpServerRequest req) {
    findRandom(ThreadLocalRandom.current(), new Handler<Message<JsonObject>>() {
      @Override
View Full Code Here

  private void sendResponse(HttpServerRequest req, String result) {
    Buffer buff = new Buffer(result);
    HttpServerResponse resp = req.response();
    setHeaders(resp, "application/json", String.valueOf(buff.length()));
    resp.end(buff);
  }

  private void setHeaders(HttpServerResponse resp, String contentType, String contentLength) {
    resp.putHeader("Content-Type", contentType);
    resp.putHeader("Content-Length", contentLength);
View Full Code Here

              String responseText = getHostPage(sessionId, username, activeClientId);
              response.statusCode = HttpStatus.SC_OK;
              byte[] page = responseText.getBytes(Charset.forName("UTF-8"));
              response.putHeader("Content-Length", page.length);
              response.putHeader("Content-Type", "text/html");
              response.end(new Buffer(page));         
            } else {
              sendRedirect(req, "/static/login.html");
            }
          }
        });
View Full Code Here

        // Set error status and end
        Response.Status status = Response.Status.INTERNAL_SERVER_ERROR;
        response.setStatusCode(status.getStatusCode());
        response.setStatusMessage(status.getReasonPhrase());
        response.end();

    }

    /**
     * {@inheritDoc}
 
View Full Code Here

                        output = words.getProperty(input);
                    }
                    if(output == null) output = UNKNOWN_WORD;

                    response.statusCode = 200;
                    response.end(output);
                } else {
                    response.statusCode = 404;
                    response.statusMessage = "Unrecognised";
                    response.end("Not found!");
                }
View Full Code Here

                    response.statusCode = 200;
                    response.end(output);
                } else {
                    response.statusCode = 404;
                    response.statusMessage = "Unrecognised";
                    response.end("Not found!");
                }
            }
        });

        server.listen(8090, "localhost");
View Full Code Here

                                response.setStatusCode(404);
                                response.setStatusMessage(HttpResponseStatus.valueOf(404).reasonPhrase());
                                if (errorHandler != null) {
                                    errorHandler.handle(request, null);
                                } else {
                                    response.end(HttpResponseStatus.valueOf(404).reasonPhrase());
                                }
                            }
                        } else {
                            request.put("error", error);
                            if (errorHandler != null) {
View Full Code Here

                                    }
                                }

                                response.setStatusCode(errorCode);
                                response.setStatusMessage(HttpResponseStatus.valueOf(errorCode).reasonPhrase());
                                response.end(HttpResponseStatus.valueOf(errorCode).reasonPhrase());
                            }
                        }
                    }
                }.handle(null);
            }
View Full Code Here

      // can also GET
      response.putHeader(ACCESS_CONTROL_ALLOW_METHODS, "GET,POST,PUT");
      response.putHeader(ACCESS_CONTROL_ALLOW_HEADERS, acRequestHeaders);
      response.putHeader(ACCESS_CONTROL_MAX_AGE, CACHE_SECONDS);

      response.end();
      return;
    } else {
      response.putHeader(ACCESS_CONTROL_EXPOSE_HEADERS, LOCATION);
    }
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.