RLiveObjectService.persist optimization

redisson/src/main/java/org/redisson/RedissonLiveObjectService.java

@@ -212,10 +212,11 @@ public class RedissonLiveObjectService implements RLiveObjectService {
                     continue;
                 }
 
-                String idFieldName = getRIdFieldName(detachedObject.getClass());
                 validateAnnotation(detachedObject, field.getName());
-                copy(detachedObject, attachedObject, Arrays.asList(idFieldName));
             }
+
+            String idFieldName = getRIdFieldName(detachedObject.getClass());
+            copy(detachedObject, attachedObject, Arrays.asList(idFieldName));
         }
 
         commandExecutor.execute();

redisson/src/main/java/org/redisson/liveobject/core/AccessorInterceptor.java

@@ -199,9 +199,11 @@ public class AccessorInterceptor {
             NamingScheme namingScheme = connectionManager.getCommandExecutor().getObjectBuilder().getNamingScheme(me.getClass().getSuperclass());
             String indexName = namingScheme.getIndexName(me.getClass().getSuperclass(), field.getName());
 
+            boolean skipExecution = false;
             CommandBatchService ce;
             if (commandExecutor instanceof CommandBatchService) {
                 ce = (CommandBatchService) commandExecutor;
+                skipExecution = true;
             } else {
                 ce = new CommandBatchService(connectionManager);
             }
@@ -213,9 +215,12 @@ public class AccessorInterceptor {
                 RMultimapAsync<Object, Object> map = new RedissonSetMultimap<>(namingScheme.getCodec(), ce, indexName);
                 map.putAsync(arg, ((RLiveObject) me).getLiveObjectId());
             }
+
+            if (!skipExecution) {
                 ce.execute();
             }
         }
+    }
 
     private String getFieldName(Method method) {
         String name = method.getName();