Skip to content

Commit 967247b

Browse files
committed
Added more information to exception message when no member of the replica set have been found that match what was requested
1 parent a2ec2d9 commit 967247b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/main/com/mongodb/DBTCPConnector.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -440,10 +440,11 @@ DBPort get( boolean keep , ReadPreference readPref, ServerAddress hostNeeded ){
440440
p = _masterPortPool.get();
441441
}
442442
else {
443-
ConnectionStatus.Node node = readPref.getNode(getReplicaSetStatus()._replicaSetHolder.get());
443+
ReplicaSetStatus.ReplicaSet replicaSet = getReplicaSetStatus()._replicaSetHolder.get();
444+
ConnectionStatus.Node node = readPref.getNode(replicaSet);
444445

445446
if (node == null)
446-
throw new MongoException("No replica set members available for query with "+readPref.toDBObject().toString());
447+
throw new MongoException("No replica set members available in " + replicaSet + " for " + readPref.toDBObject().toString());
447448

448449
p = _portHolder.get(node.getServerAddress()).get();
449450
}

0 commit comments

Comments
 (0)