org.apache.http.message.BasicHttpEntityEnclosingRequest#org.openqa.grid.common.exception.GridException源码实例Demo

private StringEntity getJsonAsEntity(String host, int port) {
    try {
        InputStream isr = Thread.currentThread().getContextClassLoader().getResourceAsStream("ondemand.json");
        String string = convert(isr, Charset.defaultCharset());
        JsonObject ondemand = new JsonParser().parse(string).getAsJsonObject();
        int maxSession =ConfigReader.getInstance().getMaxSession();
        JsonArray capsArray = ondemand.get("capabilities").getAsJsonArray();
        for (int i=0; i < capsArray.size(); i++) {
            capsArray.get(i).getAsJsonObject().addProperty("maxInstances", maxSession);
        }
        JsonObject configuration = ondemand.get("configuration").getAsJsonObject();
        configuration.addProperty("maxSession", maxSession);
        configuration.addProperty("hub", String.format("http://%s:%d", host, port));
        string = ondemand.toString();
        return new StringEntity(string);
    } catch (IOException e) {
        throw new GridException(e.getMessage(), e);
    }
}
 

private void startServerForTestSession(TestSession session) {
    try {
        SpawnedServer server = SpawnedServer.spawnInstance(session);
        String key = "http://" + server.getHost() + ":" + server.getPort();
        URL url = new URL(key);
        servers.put(key, server);
        ((ProxiedTestSlot) session.getSlot()).setRemoteURL(url);
        if (LOG.isLoggable(Level.INFO)) {
            LOG.info(String.format("Forwarding session to: %s", session.getSlot().getRemoteURL()));
            LOG.info(String.format("Counter value after incrementing: %d", counter.incrementAndGet()));
        }
    } catch (Exception e) {
        throw new GridException(e.getMessage(), e);
    }
}
 

@Override
public URL getRemoteURL() {
    boolean isRemoteURLSet = remoteURL != null;
    String u = remoteURL + getPath();
    try {
        return new URL(u);
    } catch (MalformedURLException e) {
        if (isRemoteURLSet) {
            throw new GridException("Configuration error for the node." + u + " isn't a valid URL");
        }
        else {
            return super.getRemoteURL();
        }
    }
}
 

protected void process(HttpServletRequest request, HttpServletResponse response) throws IOException {
  response.setContentType("text/json");
  response.setCharacterEncoding("UTF-8");
  response.setStatus(200);
  JSONObject res;
  try {
    res = getResponse();
    response.getWriter().print(res.toString(4));
    response.getWriter().close();
  } catch (JSONException e) {
    throw new GridException(e.getMessage());
  }

}
 

protected void process(HttpServletRequest request, HttpServletResponse response) throws IOException {
  response.setContentType("text/json");
  response.setCharacterEncoding("UTF-8");
  response.setStatus(200);
  JSONObject res;
  try {
    res = getResponse();
    response.getWriter().print(res.toString(4));
    response.getWriter().close();
  } catch (JSONException e) {
    throw new GridException(e.getMessage());
  }

}
 

@Override
public JSONObject getStatus() throws GridException {
    return null;
}