Class MongoConnectionPool

java.lang.Object
services.moleculer.mongo.MongoConnectionPool
public class MongoConnectionPool extends Object
Connection Pool for MongoDB.

Init method: init()
Destroy method: destroy()

  • Field Details

    • logger

      protected static final org.slf4j.Logger logger

    • mongoClient

      protected com.mongodb.reactivestreams.client.MongoClient mongoClient

    • mongoDatabase

      protected com.mongodb.reactivestreams.client.MongoDatabase mongoDatabase

    • connectionString

      protected String connectionString

    • database

      protected String database

    • connectionTimeout

      protected long connectionTimeout

  • Constructor Details

    • MongoConnectionPool

      public MongoConnectionPool()

  • Method Details

    • init

      public void init() throws Exception
      Throws:
      Exception

    • destroy

      public void destroy() throws Exception
      Throws:
      Exception

    • finalize

      protected void finalize() throws Throwable
      Overrides:
      finalize in class Object
      Throws:
      Throwable

    • closeResources

      protected void closeResources(boolean writeLog)

    • getMongoDatabase

      protected com.mongodb.reactivestreams.client.MongoDatabase getMongoDatabase()

    • getConnectionString

      public String getConnectionString()

    • setConnectionString

      public void setConnectionString(String connectionString)

    • getDatabase

      public String getDatabase()

    • setDatabase

      public void setDatabase(String database)

    • getConnectionTimeout

      public final long getConnectionTimeout()

    • setConnectionTimeout

      public final void setConnectionTimeout(long connectionTimeout)