polish

Author: dengliming

redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/RedisJSON.java

@@ -95,9 +95,9 @@ public RFuture<Long> delAsync(String key, String path) {
         RAssert.notEmpty(key, "key must not be empty");
 
         if (path == null) {
-            return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_DEL, key);
+            return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_DEL, key);
         }
-        return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_DEL, key, path);
+        return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_DEL, key, path);
     }
 
     /**
@@ -118,7 +118,7 @@ public RFuture<String> setAsync(String key, SetArgs setArgs) {
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(setArgs, "setArgs must not be null");
 
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, JSON_SET, setArgs.build(key).toArray());
+        return commandExecutor.writeAsync(key, StringCodec.INSTANCE, JSON_SET, setArgs.build(key).toArray());
     }
 
     /**
@@ -146,7 +146,7 @@ public <T> RFuture<T> getAsync(String key, Class<T> clazz, GetArgs getArgs) {
         RAssert.notNull(clazz, "clazz must not be null");
         RAssert.notNull(getArgs, "getArgs must not be null");
 
-        RFuture<String> getFuture = commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_GET, getArgs.build(key).toArray());
+        RFuture<String> getFuture = commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_GET, getArgs.build(key).toArray());
         return transformRPromiseResult(getFuture, clazz);
     }
 
@@ -168,7 +168,7 @@ public <T> RFuture<List<T>> mgetAsync(String path, Class<T> clazz, String... key
             args.add(key);
         }
         args.add(path);
-        RFuture<List<String>> getFuture = commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_MGET, args.toArray());
+        RFuture<List<String>> getFuture = commandExecutor.readAsync(keys[0], StringCodec.INSTANCE, JSON_MGET, args.toArray());
         getFuture.onComplete((res, e) -> {
             if (e != null) {
                 result.tryFailure(e);
@@ -202,7 +202,7 @@ public RFuture<Class> getTypeAsync(String key, String path) {
         RAssert.notNull(path, "path must not be null");
 
         RPromise result = new RedissonPromise<Class>();
-        RFuture<String> getFuture = commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_TYPE, key, path);
+        RFuture<String> getFuture = commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_TYPE, key, path);
         getFuture.onComplete((res, e) -> {
             if (e != null) {
                 result.tryFailure(e);
@@ -236,7 +236,7 @@ public RFuture<String> incrByAsync(String key, String path, long num) {
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(path, "path must not be null");
 
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, JSON_NUMINCRBY, key, path, num);
+        return commandExecutor.writeAsync(key, StringCodec.INSTANCE, JSON_NUMINCRBY, key, path, num);
     }
 
     /**
@@ -257,7 +257,7 @@ public RFuture<String> multByAsync(String key, String path, long num) {
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(path, "path must not be null");
 
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, JSON_NUMMULTBY, key, path, num);
+        return commandExecutor.writeAsync(key, StringCodec.INSTANCE, JSON_NUMMULTBY, key, path, num);
     }
 
     /**
@@ -279,7 +279,7 @@ public RFuture<Long> strAppendAsync(String key, String path, Object object) {
         RAssert.notNull(path, "path must not be null");
         RAssert.notNull(object, "object must not be null");
 
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, JSON_STRAPPEND, key, path, GsonUtils.toJson(object));
+        return commandExecutor.writeAsync(key, StringCodec.INSTANCE, JSON_STRAPPEND, key, path, GsonUtils.toJson(object));
     }
 
     /**
@@ -299,7 +299,7 @@ public RFuture<Long> strLenAsync(String key, String path) {
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(path, "path must not be null");
 
-        return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_STRLEN, key, path);
+        return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_STRLEN, key, path);
     }
 
     /**
@@ -326,7 +326,7 @@ public RFuture<Long> arrAppendAsync(String key, String path, Object... objects)
         for (Object object : objects) {
             args.add(GsonUtils.toJson(object));
         }
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, JSON_ARRAPPEND, args.toArray());
+        return commandExecutor.writeAsync(key, StringCodec.INSTANCE, JSON_ARRAPPEND, args.toArray());
     }
 
     /**
@@ -354,7 +354,7 @@ public RFuture<Long> arrInsertAsync(String key, String path, long index, Object.
         for (Object object : objects) {
             args.add(GsonUtils.toJson(object));
         }
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, JSON_ARRINSERT, args.toArray());
+        return commandExecutor.writeAsync(key, StringCodec.INSTANCE, JSON_ARRINSERT, args.toArray());
     }
 
     /**
@@ -374,7 +374,7 @@ public RFuture<Long> arrLenAsync(String key, String path) {
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(path, "path must not be null");
 
-        return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_ARRLEN, key, path);
+        return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_ARRLEN, key, path);
     }
 
     /**
@@ -396,7 +396,7 @@ public RFuture<Long> arrTrimAsync(String key, String path, long start, long stop
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(path, "path must not be null");
 
-        return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_ARRTRIM, key, path, start, stop);
+        return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_ARRTRIM, key, path, start, stop);
     }
 
     /**
@@ -420,7 +420,7 @@ public RFuture<Long> arrIndexAsync(String key, String path, Object scalar, long
         RAssert.notNull(path, "path must not be null");
         RAssert.notNull(scalar, "scalar must not be null");
 
-        return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_ARRINDEX, key, path,
+        return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_ARRINDEX, key, path,
                 GsonUtils.toJson(scalar), start, stop);
     }
 
@@ -445,7 +445,7 @@ public <T> RFuture<T> arrPopAsync(String key, String path, Class<T> clazz, long
         RAssert.notNull(path, "path must not be null");
         RAssert.notNull(clazz, "clazz must not be null");
 
-        RFuture<String> getFuture = commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_ARRPOP, key, path, index);
+        RFuture<String> getFuture = commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_ARRPOP, key, path, index);
         return transformRPromiseResult(getFuture, clazz);
     }
 
@@ -483,7 +483,7 @@ public RFuture<Long> objLenAsync(String key, String path) {
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(path, "path must not be null");
 
-        return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_OBJLEN, key, path);
+        return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_OBJLEN, key, path);
     }
 
     /**
@@ -503,7 +503,7 @@ public RFuture<List<Object>> objKeysAsync(String key, String path) {
         RAssert.notEmpty(key, "key must not be empty");
         RAssert.notNull(path, "path must not be null");
 
-        return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, JSON_OBJKEYS, key, path);
+        return commandExecutor.readAsync(key, StringCodec.INSTANCE, JSON_OBJKEYS, key, path);
     }
 
     public String getName() {