本文整理了Java中org.vertx.java.core.json.JsonObject.putBoolean()
方法的一些代码示例,展示了JsonObject.putBoolean()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JsonObject.putBoolean()
方法的具体详情如下:
包路径:org.vertx.java.core.json.JsonObject
类名称: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()));
}
}
内容来源于网络,如有侵权,请联系作者删除!