本文整理了Java中io.vertx.redis.RedisClient.delMany
方法的一些代码示例,展示了RedisClient.delMany
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisClient.delMany
方法的具体详情如下:
包路径:io.vertx.redis.RedisClient
类名称:RedisClient
方法名:delMany
[英]Delete many keys
[中]删除许多关键点
代码示例来源:origin: vert-x3/vertx-rx
/**
* Delete many keys
* @param keys List of keys to delete
* @param handler Handler for the result of this call.
* @return
*/
public io.vertx.rxjava.redis.RedisClient delMany(List<String> keys, Handler<AsyncResult<Long>> handler) {
delegate.delMany(keys, handler);
return this;
}
代码示例来源:origin: io.vertx/vertx-rx-java
/**
* Delete many keys
* @param keys List of keys to delete
* @param handler Handler for the result of this call.
* @return
*/
public io.vertx.rxjava.redis.RedisClient delMany(List<String> keys, Handler<AsyncResult<Long>> handler) {
delegate.delMany(keys, handler);
return this;
}
代码示例来源:origin: org.swisspush/redisques
/**
* Caution: this may in some corner case violate the ordering for one
* message.
*/
private void resetConsumers() {
log.debug("RedisQues Resetting consumers");
String keysPattern = getConsumersPrefix() + "*";
if (log.isTraceEnabled()) {
log.trace("RedisQues reset consumers keys: " + keysPattern);
}
redisClient.keys(keysPattern, keysResult -> {
if (keysResult.failed() || keysResult.result() == null) {
log.error("Unable to get redis keys of consumers", keysResult.cause());
return;
}
JsonArray keys = keysResult.result();
if (keys == null || keys.isEmpty()) {
log.debug("No consumers found to reset");
return;
}
redisClient.delMany(keys.getList(), delManyResult -> {
if (delManyResult.succeeded()) {
Long count = delManyResult.result();
log.debug("Successfully reset " + count + " consumers");
} else {
log.error("Unable to delete redis keys of consumers");
}
});
});
}
代码示例来源:origin: org.swisspush/redisques
private void bulkDeleteQueues(Message<JsonObject> event){
JsonArray queues = event.body().getJsonObject(PAYLOAD).getJsonArray(QUEUES);
if (queues == null) {
event.reply(createErrorReply().put(MESSAGE, "No queues to delete provided"));
return;
}
if(queues.isEmpty()){
event.reply(createOkReply().put(VALUE, 0));
return;
}
if(!jsonArrayContainsStringsOnly(queues)){
event.reply(createErrorReply().put(ERROR_TYPE, BAD_INPUT).put(MESSAGE, "Queues must be string values"));
return;
}
redisClient.delMany(buildQueueKeys(queues), delManyReply -> {
if(delManyReply.succeeded()){
event.reply(createOkReply().put(VALUE, delManyReply.result()));
} else {
log.error("Failed to bulkDeleteQueues", delManyReply.cause());
event.reply(createErrorReply());
}
});
}
内容来源于网络,如有侵权,请联系作者删除!