Retrieve replica pool without checking out a connection

Nasdaq · Dec 24, 2024 · 2c746c2 · 2c746c2
1 parent f4d8188
commit 2c746c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/active_record_proxy_adapters/primary_replica_proxy.rb b/lib/active_record_proxy_adapters/primary_replica_proxy.rb
@@ -62,11 +62,11 @@ def initialize(primary_connection)
 
     attr_reader :primary_connection, :last_write_at, :active_record_context
 
-    delegate :connected_to_stack, to: :connection_class
+    delegate :connection_handler, :connected_to_stack, to: :connection_class
     delegate :reading_role, :writing_role, to: :active_record_context
 
     def replica_pool
-      connection_class.connected_to(role: reading_role) { connection_class.connection_pool }
+      connection_handler.retrieve_connection_pool(connection_class.name, role: reading_role)
     end
 
     def connection_class