本文整理汇总了Java中io.vertx.core.impl.Arguments类的典型用法代码示例。如果您正苦于以下问题:Java Arguments类的具体用法?Java Arguments怎么用?Java Arguments使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Arguments类属于io.vertx.core.impl包,在下文中一共展示了Arguments类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: insertReturningPrimaryAsync
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public static <P extends VertxPojo, R extends UpdatableRecord<R>,T,F> F insertReturningPrimaryAsync(P object, DAO<R,P,T> dao,BiFunction<Query,Function<Long,T>,F> function){
Arguments.require(INSERT_RETURNING_SUPPORT.contains(dao.configuration().dialect()), "Only MySQL supported");
UniqueKey<?> key = dao.getTable().getPrimaryKey();
TableField<? extends Record, ?> tableField = key.getFieldsArray()[0];
Function<Long,T> keyConverter = lastId -> {
T checkedResult;
if(tableField.getType().equals(Integer.class)){
checkedResult = (T) Integer.valueOf(lastId.intValue());
}else{
checkedResult = (T) lastId;
}
return checkedResult;
};
DSLContext dslContext = DSL.using(dao.configuration());
return function.apply(dslContext.insertInto(dao.getTable()).set(dslContext.newRecord(dao.getTable(), object)).returning(key.getFields()), keyConverter);
}
开发者ID:jklingsporn,项目名称:vertx-jooq-async,代码行数:18,代码来源:VertxDAOHelper.java
示例2: MqttServerOptions
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
/**
* Create an options from JSON
*
* @param json the JSON
*/
public MqttServerOptions(JsonObject json) {
super(json);
// override the default port
this.setPort(json.getInteger("port", DEFAULT_PORT));
this.maxMessageSize = json.getInteger("maxMessageSize", DEFAULT_MAX_MESSAGE_SIZE);
this.isAutoClientId = json.getBoolean("isAutoClientId", true);
this.timeoutOnConnect = json.getInteger("timeoutOnConnect", DEFAULT_TIMEOUT_ON_CONNECT);
if ((this.maxMessageSize > 0) && (this.getReceiveBufferSize() > 0)) {
Arguments.require(this.getReceiveBufferSize() >= this.maxMessageSize,
"Receiver buffer size can't be lower than max message size");
}
}
开发者ID:vert-x3,项目名称:vertx-mqtt,代码行数:19,代码来源:MqttServerOptions.java
示例3: setReceiveBufferSize
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
@Override
public MqttServerOptions setReceiveBufferSize(int receiveBufferSize) {
if ((this.maxMessageSize > 0) && (receiveBufferSize > 0)) {
Arguments.require(receiveBufferSize >= this.maxMessageSize,
"Receiver buffer size can't be lower than max message size");
}
super.setReceiveBufferSize(receiveBufferSize);
return this;
}
开发者ID:vert-x3,项目名称:vertx-mqtt,代码行数:10,代码来源:MqttServerOptions.java
示例4: setMaxMessageSize
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
/**
* Set max MQTT message size
*
* @param maxMessageSize max MQTT message size (variable header + payload)
* @return MQTT server options instance
*/
public MqttServerOptions setMaxMessageSize(int maxMessageSize) {
Arguments.require(maxMessageSize > 0 || maxMessageSize == DEFAULT_MAX_MESSAGE_SIZE, "maxMessageSize must be > 0");
if ((maxMessageSize > 0) && (this.getReceiveBufferSize() > 0)) {
Arguments.require(this.getReceiveBufferSize() >= maxMessageSize,
"Receiver buffer size can't be lower than max message size");
}
this.maxMessageSize = maxMessageSize;
return this;
}
开发者ID:vert-x3,项目名称:vertx-mqtt,代码行数:16,代码来源:MqttServerOptions.java
示例5: setReceiveBufferSize
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
@Override
public MqttClientOptions setReceiveBufferSize(int receiveBufferSize) {
if ((this.maxMessageSize > 0) && (receiveBufferSize > 0)) {
Arguments.require(receiveBufferSize >= this.maxMessageSize,
"Receiver buffer size can't be lower than max message size");
}
super.setReceiveBufferSize(receiveBufferSize);
return this;
}
开发者ID:vert-x3,项目名称:vertx-mqtt,代码行数:10,代码来源:MqttClientOptions.java
示例6: setMaxMessageSize
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
/**
* Set max MQTT message size
*
* @param maxMessageSize max MQTT message size
* @return MQTT client options instance
*/
public MqttClientOptions setMaxMessageSize(int maxMessageSize) {
Arguments.require(maxMessageSize > 0 || maxMessageSize == DEFAULT_MAX_MESSAGE_SIZE, "maxMessageSize must be > 0");
if ((maxMessageSize > 0) && (this.getReceiveBufferSize() > 0)) {
Arguments.require(this.getReceiveBufferSize() >= maxMessageSize,
"Receiver buffer size can't be lower than max message size");
}
this.maxMessageSize = maxMessageSize;
return this;
}
开发者ID:vert-x3,项目名称:vertx-mqtt,代码行数:16,代码来源:MqttClientOptions.java
示例7: getLockWithTimeout
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
/**
* Get a local lock with the specified name with specifying a timeout. The lock will be passed to
* the handler when it is available. If the lock is not obtained within the timeout a failure
* will be sent to the handler
*
* @param name the name of the lock
* @param timeout the timeout in ms
* @param resultHandler the handler
*/
public void getLockWithTimeout(String name, long timeout,
Handler<AsyncResult<Lock>> resultHandler) {
Objects.requireNonNull(name, "name");
Objects.requireNonNull(resultHandler, "resultHandler");
Arguments.require(timeout >= 0L, "timeout must be >= 0");
AsynchronousLock lock = this.localLocks
.computeIfAbsent(name, (n) -> new AsynchronousLock(this.vertx));
lock.acquire(timeout, resultHandler);
}
开发者ID:amoAHCP,项目名称:vxms,代码行数:20,代码来源:LocalData.java
示例8: HttpResourceFetcher
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
public HttpResourceFetcher(Vertx vertx, URI uri, Map<String, String> config, boolean isHttps) {
this.vertx = vertx;
this.uri = uri;
this.isHttps = isHttps;
this.config = config;
String authString = config.getOrDefault("auth", "NONE").toUpperCase();
Arguments.require(EnumUtils.isValidEnum(AuthType.class, authString), "auth must be one of: " + AuthType.all());
authenticator = AuthType.valueOf(authString).getAuthenticator();
authenticator.validateConfig(config);
}
开发者ID:apiman,项目名称:apiman,代码行数:12,代码来源:HttpResourceFetcher.java
示例9: URILoadingRegistry
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
public URILoadingRegistry(Vertx vertx, IEngineConfig vxConfig, Map<String, String> options) {
super();
this.vertx = vertx;
this.options = options;
Arguments.require(options.containsKey("configUri"), "configUri is required in configuration");
uri = URI.create(options.get("configUri"));
}
开发者ID:apiman,项目名称:apiman,代码行数:8,代码来源:URILoadingRegistry.java
示例10: requireJsonArray
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private <T, K> List<T> requireJsonArray(String keyName, JsonObject json, Class<K> klazz) {
// Contains key.
Arguments.require(json.containsKey(keyName),
String.format("Must provide array of %s objects for key '%s'", StringUtils.capitalize(keyName), keyName));
// Is of type array.
Arguments.require(json.getValue(keyName) instanceof JsonArray,
String.format("'%s' must be a Json array", keyName));
// Transform into List<T>.
return Json.decodeValue(json.getJsonArray(keyName).encode(), List.class, klazz);
}
开发者ID:apiman,项目名称:apiman,代码行数:12,代码来源:URILoadingRegistry.java
示例11: fixedSizeMode
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
/**
* Flip the parser into fixed size mode, where the record size is specified by {@code size} in bytes.<p>
* This method can be called multiple times with different values of size while data is being parsed.
*/
private void fixedSizeMode(int size) {
Arguments.require(size > 0, "Size must be > 0");
recordSize = size;
reset = true;
}
开发者ID:blakepettersson,项目名称:reactmann,代码行数:10,代码来源:RiemannParser.java
示例12: requireOpt
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
private String requireOpt(String key, String errorMsg) {
Arguments.require(options.containsKey(key), errorMsg);
return options.get(key);
}
开发者ID:apiman,项目名称:apiman,代码行数:5,代码来源:AccessTokenResourceFetcher.java
示例13: requireOpt
import io.vertx.core.impl.Arguments; //导入依赖的package包/类
private String requireOpt(String key, String errorMsg) {
Arguments.require(config.containsKey(key), errorMsg);
return config.get(key);
}
开发者ID:apiman,项目名称:apiman,代码行数:5,代码来源:ThreeScaleImmutableRegistry.java
注:本文中的io.vertx.core.impl.Arguments类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论