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

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

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

JsonObject.containsField介绍

暂无

代码示例

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

private String chooseHashedNode(String group, int hashCode) {
 ArrayList<String> matchingMembers = new ArrayList<>();
 for (Map.Entry<String, String> entry : clusterMap.entrySet()) {
  JsonObject haInfo = new JsonObject(entry.getValue());
  if (haInfo.containsField("group") && haInfo.getString("group").equals(group)) {
   matchingMembers.add(entry.getKey());
  }
 }
 if (!matchingMembers.isEmpty()) {
  // Hashcodes can be -ve so make it positive
  long absHash = (long)hashCode + Integer.MAX_VALUE;
  long lpos = absHash % matchingMembers.size();
  return matchingMembers.get((int)lpos);
 } else {
  return null;
 }
}

代码示例来源: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: 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

if (message.body().containsField("index")) {
 final int index = message.body().getInteger("index");
 try {

相关文章