|
|
|
@ -28,6 +28,7 @@ import org.redisson.command.CommandBatchService;
|
|
|
|
|
import org.redisson.liveobject.misc.ClassUtils;
|
|
|
|
|
import org.redisson.liveobject.resolver.NamingScheme;
|
|
|
|
|
|
|
|
|
|
import java.lang.reflect.InvocationTargetException;
|
|
|
|
|
import java.lang.reflect.Method;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
@ -80,7 +81,7 @@ public class LiveObjectInterceptor {
|
|
|
|
|
@FieldValue("liveObjectLiveMap") RMap<String, ?> map,
|
|
|
|
|
@FieldProxy("liveObjectLiveMap") Setter mapSetter,
|
|
|
|
|
@FieldProxy("liveObjectLiveMap") Getter mapGetter
|
|
|
|
|
) throws Exception {
|
|
|
|
|
) throws Throwable {
|
|
|
|
|
if ("setLiveObjectId".equals(method.getName())) {
|
|
|
|
|
if (args[0].getClass().isArray()) {
|
|
|
|
|
throw new UnsupportedOperationException("RId value cannot be an array.");
|
|
|
|
@ -130,7 +131,11 @@ public class LiveObjectInterceptor {
|
|
|
|
|
return deleteFuture.getNow() > 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return method.invoke(map, args);
|
|
|
|
|
try {
|
|
|
|
|
return method.invoke(map, args);
|
|
|
|
|
} catch (InvocationTargetException e) {
|
|
|
|
|
throw e.getCause();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|