diff --git a/cassandra/pool.py b/cassandra/pool.py
index 9d716fd8..54c25c9b 100644
--- a/cassandra/pool.py
+++ b/cassandra/pool.py
@@ -234,7 +234,7 @@ class HostConnectionPool(object):
         self._conn_available_condition = Condition()
 
         core_conns = session.cluster.get_core_connections_per_host(host_distance)
-        self._connections = [session.cluster.connection_factory(host.address)
+        self._connections = [session.cluster._connection_factory(host.address)
                              for i in range(core_conns)]
         self._trash = set()
         self.open_count = core_conns
@@ -328,7 +328,7 @@ class HostConnectionPool(object):
             self.open_count += 1
 
         try:
-            conn = self._session.cluster.connection_factory(self.host)
+            conn = self._session.cluster._connection_factory(self.host)
             with self._lock:
                 self._connections.append(conn)
             self._signal_available_conn()