io.vertx.redis.RedisClient.delMany()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(121)

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

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());
    }
  });
}

相关文章

RedisClient类方法