feature: support hlen protocol

funky-eyes · Apr 18, 2024 · f1ec469 · f1ec469
1 parent 3783bf8
commit f1ec469
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 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
@@ -54,6 +54,7 @@ public void handle(RemotingContext ctx, HLenRequest 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);
             }

diff --git a/src/main/java/icu/funkye/redispike/protocol/RedisCommandDecoder.java b/src/main/java/icu/funkye/redispike/protocol/RedisCommandDecoder.java
@@ -129,6 +129,8 @@ private AbstractRedisRequest<?> convert2RedisRequest(List<String> params, boolea
             case "hexists":
                 return new HExistsRequest(params.get(1), params.get(2), flush);
             case "hlen":
+                params.remove(0);
+                return new HLenRequest(params, flush);
             case "scard":
                 return new SCardRequest(params.get(1), flush);
             case "sadd":