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

JsonObject.getObject介绍

暂无

代码示例

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

protected JsonObject getOptionalObjectConfig(String fieldName, JsonObject defaultValue) {
 JsonObject o = config.getObject(fieldName);
 return o == null ? defaultValue : o;
}

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

public JsonObject getObject(String fieldName, JsonObject def) {
 JsonObject obj = getObject(fieldName);
 return obj == null ? def : obj;
}

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

protected JsonObject getOptionalObjectConfig(String fieldName, JsonObject defaultValue) {
 JsonObject o = config.getObject(fieldName);
 return o == null ? defaultValue : o;
}

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

private JsonObject getMandatoryObject(JsonObject json, String field) {
 JsonObject value = json.getObject(field);
 if (value == null) {
  throw new IllegalStateException(field + " must be specified for message");
 }
 return value;
}

代码示例来源：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: com.englishtown/vertx-mod-cassandra

protected void initPolicies(JsonObject policyConfig) {
  if (policyConfig == null) {
    return;
  }
  initLoadBalancingPolicy(policyConfig.getObject("load_balancing"));
  initReconnectionPolicy(policyConfig.getObject("reconnection"));
}

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

protected JsonObject getMandatoryObject(String field, Message<JsonObject> message) {
 JsonObject val = message.body.getObject(field);
 if (val == null) {
  sendError(message, field + " must be specified");
 }
 return val;
}

代码示例来源：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: io.vertx/vertx-platform

protected JsonObject getMandatoryObject(String field, Message<JsonObject> message) {
 JsonObject val = message.body().getObject(field);
 if (val == null) {
  sendError(message, field + " must be specified");
 }
 return val;
}

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

@Inject
public JsonCassandraConfigurator(Container container) {
  this(container.config().getObject("cassandra", new JsonObject()), container);
}

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

@Inject
public EnvironmentCassandraConfigurator(Container container) {
  this(container.config().getObject("cassandra", new JsonObject()), container);
}

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

@Override
public void getAssignment(final String deploymentID, final Handler<AsyncResult<String>> resultHandler) {
 for (Map.Entry<String, String> entry : clusterMap.entrySet()) {
  JsonObject haInfo = new JsonObject(entry.getValue());
  JsonObject internalIDs = haInfo.getObject("internal");
  if (internalIDs != null && internalIDs.containsField(deploymentID)) {
   new DefaultFutureResult<String>(entry.getKey()).setHandler(resultHandler);
   return;
  }
 }
 new DefaultFutureResult<String>(new VertxException("Invalid deployment ID.")).setHandler(resultHandler);
}

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

@Override
 public void handle(String nodeID, JsonObject haInfo, boolean failed) {
  JsonObject jsid = haInfo.getObject("server_id");
  if (jsid != null) {
   ServerID sid = new ServerID(jsid.getInteger("port"), jsid.getString("host"));
   eb.cleanSubsForServerID(sid);
  }
 }
});

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

/**
 * Deploys one or more modules.  The Json is of the structure:
 * [ {
 * "name": "groupId~artifactId~version",
 * "instances": 1,
 * "config": {}
 * } ]
 *
 * @param modules
 * @return
 */
@Override
public List<Promise<String>> deployModules(JsonArray modules) {
  List<Promise<String>> promises = new ArrayList<>();
  if (modules == null) {
    return promises;
  }
  for (int i = 0; i < modules.size(); i++) {
    JsonObject module = modules.get(i);
    String name = module.getString("name");
    if (name != null && !name.isEmpty()) {
      int instances = module.getInteger("instances", 1);
      JsonObject config = module.getObject("config", new JsonObject());
      promises.add(deployModule(name, config, instances));
    }
  }
  return promises;
}

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

@Override
 public void handle(AsyncResult<String> result) {
  if (result.succeeded()) {
   // Tell the other nodes of the cluster about the verticle for HA purposes
   addVerticleToHA(deploymentInfo.getString("id"), result.result(), deploymentInfo.getString("main"), deploymentInfo.getObject("config"), deploymentInfo.getInteger("instances", 1), true);
   log.info("Successfully redeployed verticle " + deploymentInfo.getString("main") + " after failover");
  } else {
   log.error("Failed to redeploy verticle after failover", result.cause());
   err.set(result.cause());
  }
  latch.countDown();
  Throwable t = err.get();
  if (t != null) {
   throw new VertxException(t);
  }
 }
});

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

@Override
 public void handle(AsyncResult<String> result) {
  if (result.succeeded()) {
   // Tell the other nodes of the cluster about the module for HA purposes
   addModuleToHA(deploymentInfo.getString("id"), result.result(), deploymentInfo.getString("module"), deploymentInfo.getObject("config"), deploymentInfo.getInteger("instances", 1), true);
   log.info("Successfully redeployed module " + deploymentInfo.getString("module") + " after failover");
  } else {
   log.error("Failed to redeploy module after failover", result.cause());
   err.set(result.cause());
  }
  latch.countDown();
  Throwable t = err.get();
  if (t != null) {
   throw new VertxException(t);
  }
 }
});

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

@Override
 public void handle(AsyncResult<String> result) {
  if (result.succeeded()) {
   // Tell the other nodes of the cluster about the verticle for HA purposes
   addWorkerVerticleToHA(deploymentInfo.getString("id"), result.result(), deploymentInfo.getString("main"), deploymentInfo.getObject("config"), deploymentInfo.getInteger("instances", 1), deploymentInfo.getBoolean("multi-threaded", false), true);
   log.info("Successfully redeployed verticle " + deploymentInfo.getString("main") + " after failover");
  } else {
   log.error("Failed to redeploy verticle after failover", result.cause());
   err.set(result.cause());
  }
  latch.countDown();
  Throwable t = err.get();
  if (t != null) {
   throw new VertxException(t);
  }
 }
});

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

@Override
 public void handle(AsyncResult<Void> result) {
  if (result.succeeded()) {
   log.info("Successfully undeployed HA deployment " + deploymentInfo.getString("id") + " as there is no quorum");
   addModuleToHADeployList(deploymentID, deploymentInfo.getString("module"), deploymentInfo.getObject("config"),
     deploymentInfo.getInteger("instances"), new AsyncResultHandler<String>() {
    @Override
    public void handle(AsyncResult<String> result) {
     if (result.succeeded()) {
      log.info("Successfully redeployed module " + deploymentInfo.getString("module") + " after quorum was re-attained");
     } else {
      log.error("Failed to redeploy module " + deploymentInfo.getString("module") + " after quorum was re-attained", result.cause());
     }
    }
   });
  } else {
   log.error("Failed to undeploy deployment on lost quorum", result.cause());
  }
 }
});

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

@Override
 public void handle(AsyncResult<Void> result) {
  if (result.succeeded()) {
   log.info("Successfully undeployed HA deployment " + deploymentInfo.getString("id") + " as there is no quorum");
   addVerticleToHADeployList(deploymentID, deploymentInfo.getString("main"), deploymentInfo.getObject("config"),
     deploymentInfo.getInteger("instances"), new AsyncResultHandler<String>() {
    @Override
    public void handle(AsyncResult<String> result) {
     if (result.succeeded()) {
      log.info("Successfully redeployed verticle " + deploymentInfo.getString("main") + " after quorum was re-attained");
     } else {
      log.error("Failed to redeploy verticle " + deploymentInfo.getString("main") + " after quorum was re-attained", result.cause());
     }
    }
   });
  } else {
   log.error("Failed to undeploy deployment on lost quorum", result.cause());
  }
 }
});

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

@Override
 public void handle(AsyncResult<Void> result) {
  if (result.succeeded()) {
   log.info("Successfully undeployed HA deployment " + deploymentInfo.getString("id") + " as there is no quorum");
   addWorkerVerticleToHADeployList(deploymentID, deploymentInfo.getString("main"), deploymentInfo.getObject("config"),
     deploymentInfo.getInteger("instances"), deploymentInfo.getBoolean("multi-threaded", false), new AsyncResultHandler<String>() {
    @Override
    public void handle(AsyncResult<String> result) {
     if (result.succeeded()) {
      log.info("Successfully redeployed worker verticle " + deploymentInfo.getString("main") + " after quorum was re-attained");
     } else {
      log.error("Failed to redeploy worker verticle " + deploymentInfo.getString("main") + " after quorum was re-attained", result.cause());
     }
    }
   });
  } else {
   log.error("Failed to undeploy deployment on lost quorum", result.cause());
  }
 }
});