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

JsonObject.getArray介绍

暂无

代码示例

代码示例来源：origin: io.vertx/vertx-platform

protected JsonArray getOptionalArrayConfig(String fieldName, JsonArray defaultValue) {
 JsonArray a = config.getArray(fieldName);
 return a == null ? defaultValue : a;
}

代码示例来源：origin: org.vert-x/vertx-core

public JsonArray getArray(String fieldName, JsonArray def) {
 JsonArray arr = getArray(fieldName);
 return arr == null ? def : arr;
}

代码示例来源：origin: org.vert-x/vertx-platform

protected JsonArray getOptionalArrayConfig(String fieldName, JsonArray defaultValue) {
 JsonArray a = config.getArray(fieldName);
 return a == null ? defaultValue : a;
}

代码示例来源：origin: org.vert-x/vertx-core

public JsonElement getElement(String fieldName) {
 Object element = map.get(fieldName);
 if (element instanceof Map<?,?>){
  return this.getObject(fieldName);
 }
 if (element instanceof List<?>){
  return this.getArray(fieldName);
 }
 throw new ClassCastException();
}

代码示例来源：origin: org.vert-x/vertx-core

static Handler<HttpServerRequest> createInfoHandler(final JsonObject config) {
 return new Handler<HttpServerRequest>() {
  boolean websocket = !config.getArray("disabled_transports").contains(Transport.WEBSOCKET.toString());
  public void handle(HttpServerRequest req) {
   if (log.isTraceEnabled()) log.trace("In Info handler");
   req.response.headers().put("Content-Type", "application/json; charset=UTF-8");
   req.response.headers().put("Cache-Control", "no-store, no-cache, must-revalidate, max-age=0");
   JsonObject json = new JsonObject();
   json.putBoolean("websocket", websocket);
   json.putBoolean("cookie_needed", config.getBoolean("insert_JSESSIONID"));
   json.putArray("origins", new JsonArray().add("*:*"));
   // Java ints are signed, so we need to use a long and add the offset so
   // the result is not negative
   json.putNumber("entropy", RAND_OFFSET + new Random().nextInt());
   setCORS(req);
   req.response.end(json.encode());
  }
 };
}

代码示例来源：origin: net.kuujo/xync

@Override
public void getDeploymentInfo(final String deploymentID, final Handler<AsyncResult<JsonObject>> resultHandler) {
 for (Map.Entry<String, String> entry : clusterMap.entrySet()) {
  JsonObject haInfo = new JsonObject(entry.getValue());
  JsonArray deployments = haInfo.getArray("deployments");
  if (deployments != null) {
   for (Object dep : deployments) {
    JsonObject deployment = (JsonObject) dep;
    if (deployment.getString("id").equals(deploymentID)) {
     new DefaultFutureResult<JsonObject>(deployment.putString("node", entry.getKey())).setHandler(resultHandler);
     return;
    }
   }
  }
 }
 new DefaultFutureResult<JsonObject>(new VertxException("Invalid deployment ID.")).setHandler(resultHandler);
}

代码示例来源：origin: net.kuujo/xync

@Override
public void isDeployed(final String deploymentID, final Handler<AsyncResult<Boolean>> resultHandler) {
 Set<String> nodes = manager.getNodes();
 for (Map.Entry<String, String> entry : clusterMap.entrySet()) {
  JsonObject haInfo = new JsonObject(entry.getValue());
  String nodeID = haInfo.getString("node");
  JsonArray deployments = haInfo.getArray("deployments");
  for (Object deployment : deployments) {
   JsonObject deploymentInfo = (JsonObject) deployment;
   if (deploymentInfo.getString("id").equals(deploymentID) && (nodes.contains(nodeID) || deploymentInfo.getBoolean("ha", false))) {
    new DefaultFutureResult<Boolean>(true).setHandler(resultHandler);
    return;
   }
  }
 }
 new DefaultFutureResult<Boolean>(false).setHandler(resultHandler);
}

代码示例来源：origin: net.kuujo/xync

private void checkFailover(String failedNodeID, JsonObject theHAInfo) {
 try {
  JsonArray deployments = theHAInfo.getArray("deployments");
  String group = theHAInfo.getString("group");
  String chosen = chooseHashedNode(group, failedNodeID.hashCode());
  if (chosen != null && chosen.equals(this.node)) {
   log.info("Node " + failedNodeID + " has failed. This node will deploy " + deployments.size() + " deployments from that node.");
   if (deployments != null) {
    for (Object obj: deployments) {
     JsonObject deployment = (JsonObject)obj;
     if (deployment.getBoolean("ha", false)) {
      processFailover(deployment);
     }
    }
   }
   // Failover is complete! We can now remove the failed node from the cluster map
   clusterMap.remove(failedNodeID);
  }
 } catch (Throwable t) {
  log.error("Failed to handle failover", t);
 }
}

代码示例来源：origin: com.englishtown/vertx-mod-jersey

protected ResourceConfig getResourceConfig() {
  checkState();
  JsonArray resources = config.getArray(CONFIG_RESOURCES, null);
  JsonArray features = config.getArray(CONFIG_FEATURES, null);
  if (features != null && features.size() > 0) {
    for (int i = 0; i < features.size(); i++) {
  JsonArray binders = config.getArray(CONFIG_BINDERS, null);
  if (binders != null && binders.size() > 0) {
    for (int i = 0; i < binders.size(); i++) {

代码示例来源：origin: io.vertx/vertx-platform

private void checkFailover(String failedNodeID, JsonObject theHAInfo) {
 try {
  JsonArray deployments = theHAInfo.getArray("mods");
  String group = theHAInfo.getString("group");
  String chosen = chooseHashedNode(group, failedNodeID.hashCode());
  if (chosen != null && chosen.equals(this.nodeID)) {
   if (deployments != null && deployments.size() > 0) {
    log.info("Node " + failedNodeID + " has failed. This node will deploy " + deployments.size() + " deployments from that node.");
    for (Object obj: deployments) {
     JsonObject app = (JsonObject)obj;
     processFailover(app);
    }
   }
   // Failover is complete! We can now remove the failed node from the cluster map
   clusterMap.remove(failedNodeID);
   callFailoverCompleteHandler(failedNodeID, theHAInfo, true);
  }
 } catch (Throwable t) {
  log.error("Failed to handle failover", t);
  callFailoverCompleteHandler(failedNodeID, theHAInfo, false);
 }
}

代码示例来源：origin: org.vert-x/vertx-core

enabledTransports.add(Transport.WEBSOCKET.toString());
enabledTransports.add(Transport.XHR.toString());
for (Object tr : config.getArray("disabled_transports", new JsonArray())) {
 enabledTransports.remove(tr);

代码示例来源：origin: com.englishtown/vertx-mod-cassandra

protected void init(JsonObject config) {
  initSeeds(config.getArray(CONFIG_SEEDS));
  initPolicies(config.getObject(CONFIG_POLICIES));
  initPoolingOptions(config.getObject(CONFIG_POOLING));
  initSocketOptions(config.getObject(CONFIG_SOCKET));
  initQueryOptions(config);
  initMetricsOptions(config.getObject(CONFIG_METRICS));
  initAuthProvider(config.getObject(CONFIG_AUTH));
}

代码示例来源：origin: org.vert-x/vertx-core

private JsonObject setDefaults(JsonObject config) {
 config = config.copy();
 //Set the defaults
 if (config.getNumber("session_timeout") == null) {
  config.putNumber("session_timeout", 5 * 1000); // 5 seconds default
 }
 if (config.getBoolean("insert_JSESSIONID") == null) {
  config.putBoolean("insert_JSESSIONID", true);
 }
 if (config.getNumber("heartbeat_period") == null) {
  config.putNumber("heartbeat_period", 5l * 1000);
 }
 if (config.getNumber("max_bytes_streaming") == null) {
  config.putNumber("max_bytes_streaming", 128 * 1024);
 }
 if (config.getString("prefix") == null) {
  config.putString("prefix", "/");
 }
 if (config.getString("library_url") == null) {
  config.putString("library_url", "http://cdn.sockjs.org/sockjs-0.2.1.min.js");
 }
 if (config.getArray("disabled_transports") == null) {
  config.putArray("disabled_transports", new JsonArray());
 }
 return config;
}