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 c6c2986..e9c175f 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 @@ -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 index bbaed84..1c1911a 100644 --- 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 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":