refactoring

pull/6244/head
Nikita Koksharov 4 months ago
parent c9cd7d5c57
commit c5210bbcba

@ -121,15 +121,10 @@ public class AccessorInterceptor {
removeIndex(liveMap, me, field);
storeIndex(field, me, liveObject.getLiveObjectId());
Class<? extends Object> rEntity = liveObject.getClass().getSuperclass();
NamingScheme ns = commandExecutor.getObjectBuilder().getNamingScheme(rEntity);
if (commandExecutor instanceof CommandBatchService) {
liveMap.fastPutAsync(fieldName, new RedissonReference(rEntity,
ns.getName(rEntity, liveObject.getLiveObjectId())));
liveMap.fastPutAsync(fieldName, liveObject);
} else {
liveMap.fastPut(fieldName, new RedissonReference(rEntity,
ns.getName(rEntity, liveObject.getLiveObjectId())));
liveMap.fastPut(fieldName, liveObject);
}
return me;

@ -102,21 +102,11 @@ public class RedissonObjectBuilder {
}
public void storeAsync(RObject ar, String fieldName, RMap<String, Object> liveMap) {
Codec codec = ar.getCodec();
if (codec != null) {
codecProvider.registerCodec((Class) codec.getClass(), codec);
}
liveMap.fastPutAsync(fieldName,
new RedissonReference(ar.getClass(), ar.getName(), codec));
liveMap.fastPutAsync(fieldName, ar);
}
public void store(RObject ar, String fieldName, RMap<String, Object> liveMap) {
Codec codec = ar.getCodec();
if (codec != null) {
codecProvider.registerCodec((Class) codec.getClass(), codec);
}
liveMap.fastPut(fieldName,
new RedissonReference(ar.getClass(), ar.getName(), codec));
liveMap.fastPut(fieldName, ar);
}
public RObject createObject(Object id, Class<?> clazz, Class<?> fieldType, String fieldName) {

Loading…
Cancel
Save