本文整理了Java中io.vertx.redis.RedisClient.hdel
方法的一些代码示例,展示了RedisClient.hdel
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisClient.hdel
方法的具体详情如下:
包路径:io.vertx.redis.RedisClient
类名称:RedisClient
方法名:hdel
[英]Delete one or more hash fields
[中]删除一个或多个哈希字段
代码示例来源:origin: vert-x3/vertx-rx
/**
* Delete one or more hash fields
* @param key Key string
* @param field Field name
* @param handler Handler for the result of this call.
* @return
*/
public io.vertx.rxjava.redis.RedisClient hdel(String key, String field, Handler<AsyncResult<Long>> handler) {
delegate.hdel(key, field, handler);
return this;
}
代码示例来源:origin: io.vertx/vertx-rx-java
/**
* Delete one or more hash fields
* @param key Key string
* @param field Field name
* @param handler Handler for the result of this call.
* @return
*/
public io.vertx.rxjava.redis.RedisClient hdel(String key, String field, Handler<AsyncResult<Long>> handler) {
delegate.hdel(key, field, handler);
return this;
}
代码示例来源:origin: io.vertx/vertx-service-discovery-backend-redis
@Override
public void remove(String uuid, Handler<AsyncResult<Record>> resultHandler) {
Objects.requireNonNull(uuid, "No registration id in the record");
redis.hget(key, uuid, ar -> {
if (ar.succeeded()) {
if (ar.result() != null) {
redis.hdel(key, uuid, deletion -> {
if (deletion.succeeded()) {
resultHandler.handle(Future.succeededFuture(
new Record(new JsonObject(ar.result()))));
} else {
resultHandler.handle(Future.failedFuture(deletion.cause()));
}
});
} else {
resultHandler.handle(Future.failedFuture("Record '" + uuid + "' not found"));
}
} else {
resultHandler.handle(Future.failedFuture(ar.cause()));
}
});
}
代码示例来源:origin: vert-x3/vertx-service-discovery
@Override
public void remove(String uuid, Handler<AsyncResult<Record>> resultHandler) {
Objects.requireNonNull(uuid, "No registration id in the record");
redis.hget(key, uuid, ar -> {
if (ar.succeeded()) {
if (ar.result() != null) {
redis.hdel(key, uuid, deletion -> {
if (deletion.succeeded()) {
resultHandler.handle(Future.succeededFuture(
new Record(new JsonObject(ar.result()))));
} else {
resultHandler.handle(Future.failedFuture(deletion.cause()));
}
});
} else {
resultHandler.handle(Future.failedFuture("Record '" + uuid + "' not found"));
}
} else {
resultHandler.handle(Future.failedFuture(ar.cause()));
}
});
}
代码示例来源:origin: org.swisspush.gateleen/gateleen-hook
@Override
public Future<Void> removeQueueRequest(String queue) {
Future<Void> future = Future.future();
if(StringUtils.isEmpty(queue)){
future.fail("Queue is not allowed to be empty");
return future;
}
redisClient.hdel(QUEUE_REQUESTS, queue, reply -> {
if(reply.failed()){
String message = "Failed to remove request for queue '"+queue+"'. Cause: " + logCause(reply);
log.error(message);
future.fail(message);
} else {
future.complete();
}
});
return future;
}
代码示例来源:origin: org.swisspush/redisques
private void deleteLock(Message<JsonObject> event) {
String queueName = event.body().getJsonObject(PAYLOAD).getString(QUEUENAME);
redisClient.exists(getQueuesPrefix() + queueName, event1 -> {
if (event1.succeeded() && event1.result() != null && event1.result() == 1) {
notifyConsumer(queueName);
}
redisClient.hdel(getLocksKey(), queueName, new DeleteLockHandler(event));
});
}
代码示例来源:origin: org.swisspush/redisques
private void deleteAllQueueItems(Message<JsonObject> event) {
JsonObject payload = event.body().getJsonObject(PAYLOAD);
boolean unlock = payload.getBoolean(UNLOCK, false);
String queue = payload.getString(QUEUENAME);
redisClient.del(buildQueueKey(queue), deleteReply -> {
if (deleteReply.failed()) {
log.warn("Failed to deleteAllQueueItems. But we'll continue anyway. _dfc641c96464_", deleteReply.cause());
// May we should 'fail()' here. But:
// 1st: We don't, to keep backward compatibility
// 2nd: We don't, to may unlock below.
}
if (unlock) {
redisClient.hdel(getLocksKey(), queue, unlockReply -> {
if (unlockReply.failed()) {
log.warn("Failed to unlock queue '{}'. Will continue anyway _d08ae0e0986587_.", queue, unlockReply.cause());
// IMO we should 'fail()' here. But we don't, to keep backward compatibility.
}
replyResultGreaterThanZero(event, deleteReply);
});
} else {
replyResultGreaterThanZero(event, deleteReply);
}
});
}
内容来源于网络,如有侵权,请联系作者删除!