refactoring

pull/6222/head
Nikita Koksharov 6 months ago
parent bfe5b2ed7b
commit 46940d3652

@ -16,7 +16,6 @@
package org.redisson.misc; package org.redisson.misc;
import org.redisson.api.RFuture; import org.redisson.api.RFuture;
import org.redisson.connection.ServiceManager;
import java.lang.reflect.InvocationHandler; import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method; import java.lang.reflect.Method;
@ -69,7 +68,7 @@ public class ProxyBuilder {
private static final ConcurrentMap<CacheKey, Method> METHODS_MAPPING = new ConcurrentHashMap<CacheKey, Method>(); private static final ConcurrentMap<CacheKey, Method> METHODS_MAPPING = new ConcurrentHashMap<CacheKey, Method>();
public static <T> T create(Callback commandExecutor, Object instance, Object implementation, Class<T> clazz, ServiceManager serviceManager) { public static <T> T create(Callback commandExecutor, Object instance, Object implementation, Class<T> clazz) {
InvocationHandler handler = new InvocationHandler() { InvocationHandler handler = new InvocationHandler() {
@Override @Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

@ -46,7 +46,7 @@ public class ReactiveProxyBuilder {
} }
return result; return result;
} }
}, instance, implementation, clazz, commandExecutor.getServiceManager()); }, instance, implementation, clazz);
} }
} }

@ -50,7 +50,7 @@ public class RxProxyBuilder {
} }
return flowable.singleElement(); return flowable.singleElement();
} }
}, instance, implementation, clazz, commandExecutor.getServiceManager()); }, instance, implementation, clazz);
} }
} }

Loading…
Cancel
Save