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

JsonObject.getBoolean介绍

暂无

代码示例

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

/**
 * Whether the web server should be https.
 *
 * @return whether the web server should be https.
 */
@Override
public boolean getSSL() {
  return config.getBoolean(CONFIG_SSL, false);
}

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

private boolean getBooleanField(String name) {
 Boolean res = conf.getBoolean(name);
 if (res == null) {
  res = Boolean.FALSE;
 }
 return res;
}

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

public boolean getBoolean(String fieldName, boolean def) {
 Boolean b = getBoolean(fieldName);
 return b == null ? def : b;
}

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

protected boolean getMandatoryBooleanConfig(String fieldName) {
 Boolean b = config.getBoolean(fieldName);
 if (b == null) {
  throw new IllegalArgumentException(fieldName + " must be specified in config for busmod");
 }
 return b;
}

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

protected boolean getMandatoryBooleanConfig(String fieldName) {
 Boolean b = config.getBoolean(fieldName);
 if (b == null) {
  throw new IllegalArgumentException(fieldName + " must be specified in config for busmod");
 }
 return b;
}

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

protected boolean getOptionalBooleanConfig(String fieldName, boolean defaultValue) {
 Boolean b = config.getBoolean(fieldName);
 return b == null ? defaultValue : b.booleanValue();
}

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

protected boolean getOptionalBooleanConfig(String fieldName, boolean defaultValue) {
 Boolean b = config.getBoolean(fieldName);
 return b == null ? defaultValue : b.booleanValue();
}

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

protected void initMetricsOptions(JsonObject metrics) {
  if (metrics == null) {
    return;
  }
  boolean jmx_enabled = metrics.getBoolean("jmx_enabled", true);
  metricsOptions = new MetricsOptions(jmx_enabled);
}

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

static void setJSESSIONID(JsonObject config, HttpServerRequest req) {
 String cookies = req.headers().get("cookie");
 if (config.getBoolean("insert_JSESSIONID")) {
  //Preserve existing JSESSIONID, if any
  if (cookies != null) {
   String[] parts;
   if (cookies.contains(";")) {
    parts = cookies.split(";");
   } else {
    parts = new String[] {cookies};
   }
   for (String part: parts) {
    if (part.startsWith("JSESSIONID")) {
     cookies = part + "; path=/";
     break;
    }
   }
  }
  if (cookies == null) {
   cookies = "JSESSIONID=dummy; path=/";
  }
  req.response.headers().put("Set-Cookie", cookies);
 }
}

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

return;
Boolean worker = conf.getBoolean("worker");
if (worker == null) {
 worker = Boolean.FALSE;
Boolean preserveCwd = conf.getBoolean("preserve-cwd");
if (preserveCwd == null) {
 preserveCwd = Boolean.FALSE;
Boolean ar = conf.getBoolean("auto-redeploy");
final boolean autoRedeploy = ar == null ? false : ar;

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

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 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: com.englishtown/vertx-mod-cassandra

Boolean keep_alive = socketConfig.getBoolean("keep_alive");
Boolean reuse_address = socketConfig.getBoolean("reuse_address");
Integer receive_buffer_size = socketConfig.getInteger("receive_buffer_size");
Integer send_buffer_size = socketConfig.getInteger("send_buffer_size");
Integer so_linger = socketConfig.getInteger("so_linger");
Boolean tcp_no_delay = socketConfig.getBoolean("tcp_no_delay");

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

Boolean b = matchHolder.getBoolean("requires_auth");
return new Match(true, b != null && b);

代码示例来源：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());
  }
 }
});

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

boolean worker = message.body().getBoolean("worker", false);
boolean ha = message.body().getBoolean("ha", false);
 boolean multiThreaded = message.body().getBoolean("multi-threaded", false);
 platform.deployWorkerVerticleAs(deploymentID, main, config, instances, multiThreaded, ha, new Handler<AsyncResult<String>>() {
  @Override

代码示例来源：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;
}

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

/**
 * Handles deployment of a module.
 */
private void doDeployModule(final Message<JsonObject> message) {
 final String deploymentID = message.body().getString("id");
 if (deploymentID == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No deployment ID specified."));
  return;
 }
 String module = message.body().getString("module");
 if (module == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No module name specified."));
  return;
 }
 JsonObject config = message.body().getObject("config");
 int instances = message.body().getInteger("instances", 1);
 boolean ha = message.body().getBoolean("ha", false);
 platform.deployModuleAs(deploymentID, module, config, instances, ha, new Handler<AsyncResult<String>>() {
  @Override
  public void handle(AsyncResult<String> result) {
   if (result.failed()) {
    message.reply(new JsonObject().putString("status", "error").putString("message", result.cause().getMessage()));
   } else {
    message.reply(new JsonObject().putString("status", "ok").putString("id", result.result()));
   }
  }
 });
}