We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b4d397c commit 3ffa863Copy full SHA for 3ffa863
1 file changed
driver-core/src/test/java/com/datastax/driver/core/ClusterInitTest.java
@@ -92,10 +92,7 @@ public void should_wait_for_each_contact_point_at_most_once() {
92
93
// We have one live host so 2 successful connections (1 control connection and 1 core connection in the pool).
94
// The other 5 hosts are unreachable, we should attempt to connect to each of them only once.
95
- int coreConnections = cluster.getConfiguration()
96
- .getPoolingOptions()
97
- .getCoreConnectionsPerHost(HostDistance.LOCAL);
98
- verify(socketOptions, times(1 + coreConnections + 5)).getKeepAlive();
+ verify(socketOptions, times(1 + TestUtils.numberOfLocalCoreConnections(cluster) + 5)).getKeepAlive();
99
} finally {
100
if (cluster != null)
101
cluster.close();
0 commit comments