diff --git a/redisson/src/main/java/org/redisson/misc/ProxyBuilder.java b/redisson/src/main/java/org/redisson/misc/ProxyBuilder.java index d93436a31..2cb9f8073 100644 --- a/redisson/src/main/java/org/redisson/misc/ProxyBuilder.java +++ b/redisson/src/main/java/org/redisson/misc/ProxyBuilder.java @@ -16,6 +16,7 @@ package org.redisson.misc; import org.redisson.api.RFuture; +import org.redisson.connection.ServiceManager; import java.lang.reflect.InvocationHandler; import java.lang.reflect.Method; @@ -68,7 +69,7 @@ public class ProxyBuilder { private static final ConcurrentMap METHODS_MAPPING = new ConcurrentHashMap(); - public static T create(Callback commandExecutor, Object instance, Object implementation, Class clazz) { + public static T create(Callback commandExecutor, Object instance, Object implementation, Class clazz, ServiceManager serviceManager) { InvocationHandler handler = new InvocationHandler() { @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { diff --git a/redisson/src/main/java/org/redisson/reactive/ReactiveProxyBuilder.java b/redisson/src/main/java/org/redisson/reactive/ReactiveProxyBuilder.java index 68039b395..a85bad19e 100644 --- a/redisson/src/main/java/org/redisson/reactive/ReactiveProxyBuilder.java +++ b/redisson/src/main/java/org/redisson/reactive/ReactiveProxyBuilder.java @@ -46,7 +46,7 @@ public class ReactiveProxyBuilder { } return result; } - }, instance, implementation, clazz); + }, instance, implementation, clazz, commandExecutor.getServiceManager()); } } diff --git a/redisson/src/main/java/org/redisson/rx/RxProxyBuilder.java b/redisson/src/main/java/org/redisson/rx/RxProxyBuilder.java index e7999e567..d48299bb5 100644 --- a/redisson/src/main/java/org/redisson/rx/RxProxyBuilder.java +++ b/redisson/src/main/java/org/redisson/rx/RxProxyBuilder.java @@ -50,7 +50,7 @@ public class RxProxyBuilder { } return flowable.singleElement(); } - }, instance, implementation, clazz); + }, instance, implementation, clazz, commandExecutor.getServiceManager()); } }