From b72ec1f80249c97d04583507ce79c3b993dbf102 Mon Sep 17 00:00:00 2001 From: jianbin Date: Thu, 18 Apr 2024 09:22:28 +0800 Subject: [PATCH] feature: support hlen protocol --- .../process/impl/hash/HLenRequestProcessor.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HLenRequestProcessor.java b/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HLenRequestProcessor.java index e9c175f..00727d0 100644 --- a/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HLenRequestProcessor.java +++ b/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HLenRequestProcessor.java @@ -51,19 +51,24 @@ public HLenRequestProcessor() { @Override public void handle(RemotingContext ctx, HLenRequest request) { Key key = new Key(AeroSpikeClientFactory.namespace, AeroSpikeClientFactory.set, request.getKey()); - client.execute(AeroSpikeClientFactory.eventLoops.next(), new ExecuteListener() { + Object object = client.execute(client.getWritePolicyDefault(), key, "hlen", "hash_count_bins"); + logger.info("hlen object:{}", object); + request.setResponse(object.toString()); + logger.info("hlen response:{}", request); + write(ctx, request); + /*client.execute(AeroSpikeClientFactory.eventLoops.next(), new ExecuteListener() { @Override public void onSuccess(Key key, Object obj) { logger.info("hlen response:{}", request); request.setResponse(obj.toString()); write(ctx, request); } - + @Override public void onFailure(AerospikeException exception) { logger.error(exception.getMessage(), exception); write(ctx, request); } - }, client.getWritePolicyDefault(), key, "hlen", "hash_count_bins"); + }, client.getWritePolicyDefault(), key, "hlen", "hash_count_bins");*/ } }