org.vertx.java.core.json.JsonObject.getInteger()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(11.6k)|赞(0)|评价(0)|浏览(132)

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

JsonObject.getInteger介绍

暂无

代码示例

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

/**
 * The accept backlog
 *
 * @return the accept backlog
 */
@Override
public int getAcceptBacklog() {
  checkState();
  return config.getInteger(CONFIG_BACKLOG_SIZE, 10000);
}

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

/**
 * The http web server port
 *
 * @return the http web server port to listen to
 */
@Override
public int getPort() {
  checkState();
  return config.getInteger(CONFIG_PORT, 80);
}

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

/**
 * The TCP receive buffer size for connections in bytes
 *
 * @return buffer size in bytes
 */
@Override
public Integer getReceiveBufferSize() {
  checkState();
  return config.getInteger(CONFIG_RECEIVE_BUFFER_SIZE);
}

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

int usedHostsPerRemoteDc = loadBalancing.getInteger("used_hosts_per_remote_dc", 0);

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

Integer delay = reconnection.getInteger("delay");

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

public void handle(final HttpServerRequest req) {
  if (log.isTraceEnabled()) log.trace("EventSource transport, get: " + req.uri);
  String sessionID = req.params().get("param0");
  Session session = getSession(config.getLong("session_timeout"), config.getLong("heartbeat_period"), sessionID, sockHandler);
  session.register(new EventSourceListener(config.getInteger("max_bytes_streaming"), req, session));
 }
});

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

public void handle(final HttpServerRequest req) {
  if (log.isTraceEnabled()) log.trace("HtmlFile, get: " + req.uri);
  String callback = req.params().get("callback");
  if (callback == null) {
   callback = req.params().get("c");
   if (callback == null) {
    req.response.statusCode = 500;
    req.response.end("\"callback\" parameter required\n");
    return;
   }
  }
  String sessionID = req.params().get("param0");
  Session session = getSession(config.getLong("session_timeout"), config.getLong("heartbeat_period"), sessionID, sockHandler);
  session.register(new HtmlFileListener(config.getInteger("max_bytes_streaming"), req, callback, session));
 }
});

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

public void handle(final HttpServerRequest req) {
  if (log.isTraceEnabled()) log.trace("XHR, post, " + req.uri);
  String sessionID = req.params().get("param0");
  Session session = getSession(config.getLong("session_timeout"), config.getLong("heartbeat_period"), sessionID, sockHandler);
  session.register(streaming? new XhrStreamingListener(config.getInteger("max_bytes_streaming"), req, session) : new XhrPollingListener(req, session));
 }
});

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

代码示例来源：origin: RichardHightower/slumberdb

public void start() {
  logger.info("Data Store Service Starting");
  try {
    config = DataStoreServerConfig.load();
    dataStoreServer.init(config);
    JsonObject configOverrides = container.config();
    if (configOverrides.containsField("port")) {
      config.port(configOverrides.getInteger("port"));
    }
    puts("SERVER CONFIG", config.port());
    configureAndStartHttpServer(dataStoreServer.getServicesDefinition());
  } catch (Throwable ex) {
    logger.error(ex, "Data Store Service Starting FAILED");
  }
}

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

/**
 * Handles a list get.
 */
private void doListGet(final Message<JsonObject> message) {
 final String name = message.body().getString("name");
 if (name == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No name specified."));
  return;
 }
 final Integer index = message.body().getInteger("index");
 if (index == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No index specified."));
  return;
 }
 try {
  Object result = manager.getList(formatKey(name)).get(index);
  message.reply(new JsonObject().putString("status", "ok").putValue("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

final int index = message.body().getInteger("index");
try {
 Object result = manager.getList(formatKey(name)).remove(index);

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

内容来源于网络，如有侵权，请联系作者删除！

JSONObject

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com