From 05a2d1b2e27d7d56c78dc0cba3131afdd63bd0a8 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Thu, 10 Oct 2024 16:22:24 +0300
Subject: [PATCH] refactoring

---
 redisson/src/main/java/org/redisson/misc/ProxyBuilder.java     | 3 ++-
 .../main/java/org/redisson/reactive/ReactiveProxyBuilder.java  | 2 +-
 redisson/src/main/java/org/redisson/rx/RxProxyBuilder.java     | 2 +-
 3 files changed, 4 insertions(+), 3 deletions(-)

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<CacheKey, Method> METHODS_MAPPING = new ConcurrentHashMap<CacheKey, Method>();
 
-    public static <T> T create(Callback commandExecutor, Object instance, Object implementation, Class<T> clazz) {
+    public static <T> T create(Callback commandExecutor, Object instance, Object implementation, Class<T> 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());
     }
     
 }