assertSame(ReadPreference.nearest(), endpoint.getMongoConnection().getReadPreference());
}
private MongoDbEndpoint createMongoDbEndpoint(String uri) throws Exception {
Endpoint endpoint = context().getComponent("mongodb").createEndpoint(uri);
endpoint.start();
return (MongoDbEndpoint) endpoint;
}
}