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

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

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

JsonObject.putBoolean介绍

暂无

代码示例

代码示例来源:origin: OlivierCroisier/LP4J

/**
 * {@inheritDoc}
 *
 * @param visibleBuffer The buffer to display. Must not be null.
 * @param writeBuffer The buffer to which the commands are applied. Must not be null.
 */
@Override
public void setBuffers(Buffer visibleBuffer, Buffer writeBuffer, boolean copyVisibleBufferToWriteBuffer, boolean autoSwap) {
  if (visibleBuffer == null) {
    throw new IllegalArgumentException("Visible buffer must not be null.");
  }
  if (writeBuffer == null) {
    throw new IllegalArgumentException("Write buffer must not be null.");
  }
  JsonObject params = new JsonObject()
      .putString("v", visibleBuffer.name())
      .putString("w", writeBuffer.name())
      .putBoolean("c", copyVisibleBufferToWriteBuffer)
      .putBoolean("a", autoSwap);
  publishEvent(OutputEventType.BUF, params);
}

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

private void addWorkerVerticleToHA(String deploymentID, String internalID, String main, JsonObject conf, int instances, boolean multiThreaded, boolean ha) {
 JsonObject info = new JsonObject()
   .putString("id", deploymentID)
   .putString("type", "verticle")
   .putString("group", group)
   .putString("main", main)
   .putObject("config", conf)
   .putNumber("instances", instances)
   .putBoolean("worker", true)
   .putBoolean("multi-threaded", multiThreaded)
   .putBoolean("ha", ha);
 synchronized (haInfo) {
  deployments.addObject(info);
  deploymentIDs.putString(internalID, deploymentID);
  internalIDs.putString(deploymentID, internalID);
 }
 clusterMap.put(node, haInfo.encode());
}

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

@Override
 public void handle(AsyncResult<Boolean> result) {
  if (result.failed()) {
   message.reply(new JsonObject().putString("status", "error").putString("message", result.cause().getMessage()));
  } else {
   message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result.result()));
  }
 }
});

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

private void addVerticleToHA(String deploymentID, String internalID, String main, JsonObject conf, int instances, boolean ha) {
 JsonObject info = new JsonObject()
   .putString("id", deploymentID)
   .putString("type", "verticle")
   .putString("group", group)
   .putString("main", main)
   .putObject("config", conf)
   .putNumber("instances", instances)
   .putBoolean("ha", ha);
 synchronized (haInfo) {
  deployments.addObject(info);
  deploymentIDs.putString(internalID, deploymentID);
  internalIDs.putString(deploymentID, internalID);
 }
 clusterMap.put(node, haInfo.encode());
}

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

private void addModuleToHA(String deploymentID, String internalID, String moduleName, JsonObject conf, int instances, boolean ha) {
 JsonObject info = new JsonObject()
   .putString("id", deploymentID)
   .putString("type", "module")
   .putString("group", group)
   .putString("module", moduleName)
   .putObject("config", conf)
   .putNumber("instances", instances)
   .putBoolean("ha", ha);
 synchronized (haInfo) {
  deployments.addObject(info);
  deploymentIDs.putString(internalID, deploymentID);
  internalIDs.putString(deploymentID, internalID);
 }
 clusterMap.put(node, haInfo.encode());
}

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

/**
 * Handles cluster set is empty command.
 */
private void doSetIsEmpty(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;
 }
 try {
  boolean result = manager.getSet(formatKey(name)).isEmpty();
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles cluster map is empty command.
 */
private void doMapIsEmpty(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;
 }
 try {
  boolean result = manager.getMap(formatKey(name)).isEmpty();
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles cluster queue is empty command.
 */
private void doQueueIsEmpty(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;
 }
 try {
  boolean result = manager.getQueue(formatKey(name)).isEmpty();
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles cluster list is empty command.
 */
private void doListIsEmpty(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;
 }
 try {
  boolean result = manager.getList(formatKey(name)).isEmpty();
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Checks whether a queue contains a value.
 */
private void doQueueContains(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
  return;
 }
 try {
  boolean result = manager.getQueue(formatKey(name)).contains(value);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles a cluster exists command.
 */
private void doMapContainsKey(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 String key = message.body().getString("key");
 if (key == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No key specified."));
  return;
 }
 try {
  boolean result = manager.getMap(formatKey(name)).containsKey(key);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles a list addition.
 */
private void doListAdd(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
  return;
 }
 try {
  boolean result = manager.getList(formatKey(name)).add(value);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles a set removal.
 */
private void doSetRemove(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
 } else {
  try {
   boolean result = manager.getSet(formatKey(name)).remove(value);
   message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
  } catch (Exception e) {
   message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
  }
 }
}

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

/**
 * Checks whether a set contains a value.
 */
private void doSetContains(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
  return;
 }
 try {
  boolean result = manager.getSet(formatKey(name)).contains(value);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles a queue addition.
 */
private void doQueueAdd(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
  return;
 }
 try {
  boolean result = manager.getQueue(formatKey(name)).add(value);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles a queue removal.
 */
private void doQueueRemove(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
 } else {
  try {
   boolean result = manager.getQueue(formatKey(name)).remove(value);
   message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
  } catch (Exception e) {
   message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
  }
 }
}

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

/**
 * Checks whether a list contains a value.
 */
private void doListContains(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
  return;
 }
 try {
  boolean result = manager.getList(formatKey(name)).contains(value);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles a set addition.
 */
private void doSetAdd(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
  return;
 }
 try {
  boolean result = manager.getSet(formatKey(name)).add(value);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

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

/**
 * Handles a queue offer command.
 */
private void doQueueOffer(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 Object value = message.body().getValue("value");
 if (value == null) {
  message.reply(new JsonObject().putString("status", "error").putString("message", "No value specified."));
  return;
 }
 try {
  boolean result = manager.getQueue(formatKey(name)).offer(value);
  message.reply(new JsonObject().putString("status", "ok").putBoolean("result", result));
 } catch (Exception e) {
  message.reply(new JsonObject().putString("status", "error").putString("message", e.getMessage()));
 }
}

相关文章