Collectives™ on Stack Overflow

Find centralized, trusted content and collaborate around the technologies you use most.

Teams

Q&A for work

Connect and share knowledge within a single location that is structured and easy to search.

No server chosen by com.mongodb.async.client.ClientSessionHelpe from cluster description ClusterDescription

I am trying to connect to aws DocumentDB with async mongoClient.

I created a DocumentDB cluster in aws and success connect via ssh command line.

I went over here and created MongoClient and success connected and insert events.

But when I tried create com.mongodb.async.client.MongoClient, connection failed with folowing error:

No server chosen by WritableServerSelector from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=aws-cluster:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSocketReadTimeoutException: Timeout while receiving message}, caused by {io.netty.handler.timeout.ReadTimeoutException}}]}. Waiting for 30000 ms before timing out.

    ClusterSettings clusterSettings = ClusterSettings.builder()
                .applyConnectionString(new ConnectionString(connectionString)).build();
        List<MongoCredential> credentials = new ArrayList<>();
        credentials.add(
                 MongoCredential.createCredential(
                         mongoUserName,
                         mongoDBName,
                         mongoPassword));
    MongoClientSettings settings = MongoClientSettings.builder()
            .credentialList(credentials)
            .clusterSettings(clusterSettings)
            .streamFactoryFactory(new NettyStreamFactoryFactory())
            .writeConcern(WriteConcern.ACKNOWLEDGED)
            .build();
    com.mongodb.async.client.MongoClient mongoClient = MongoClients.create(settings);
    MongoDatabase testDB = mongoClient.getDatabase("myDB");
    MongoCollection<Document> collection = testDB.getCollection("test");
    Document doc = new Document("name", "MongoDB").append("type", "database");
    //**trying insert document => here I got an error**
    collection.insertOne(doc, new SingleResultCallback<Void>() {
            @Override
            public void onResult(final Void result, final Throwable t) {
                System.out.println("Inserted!");
Do you have any ideas, why does it happen?
I solved it by using uri:
String uri = "mongodb://<username>:<Password>@<hostname>:27017/?ssl=true&ssl_ca_certs=cert";
MongoClientSettings settings = MongoClientSettings.builder()
                        .streamFactoryFactory(new NettyStreamFactoryFactory())
                        .applyConnectionString(new ConnectionString(uri))
                        .build();
com.mongodb.async.client.MongoClient mongoClient = MongoClients.create(settings);
        
Thanks for contributing an answer to Stack Overflow!
Please be sure to answer the question. Provide details and share your research!
But avoid …
Asking for help, clarification, or responding to other answers.
Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.