test_class.declarator: KNOWN_MAX_POOL_SIZE = 100
test_class.modifier: private static final
test_class.original_string: private static final int KNOWN_MAX_POOL_SIZE = 100;
test_class.type: int
test_class.var_name: KNOWN_MAX_POOL_SIZE
test_class.declarator: KNOWN_MAX_POOL_WAIT_QUEUE_SIZE = 5000
test_class.modifier: private static final
test_class.original_string: private static final int KNOWN_MAX_POOL_WAIT_QUEUE_SIZE = 5000;
test_class.type: int
test_class.var_name: KNOWN_MAX_POOL_WAIT_QUEUE_SIZE
test_class.declarator: KNOWN_MAX_POOL_WAIT_SECS = 10L
test_class.modifier: private static final
test_class.original_string: private static final long KNOWN_MAX_POOL_WAIT_SECS = 10L;
test_class.type: long
test_class.var_name: KNOWN_MAX_POOL_WAIT_SECS
test_class.declarator: KNOWN_DB_NAME = "someGeneratedName"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_DB_NAME = "someGeneratedName";
test_class.type: String
test_class.var_name: KNOWN_DB_NAME
test_class.declarator: KNOWN_USER = "theUser"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_USER = "theUser";
test_class.type: String
test_class.var_name: KNOWN_USER
test_class.declarator: KNOWN_PASSWORD = "thePassword"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_PASSWORD = "thePassword";
test_class.type: String
test_class.var_name: KNOWN_PASSWORD
test_class.declarator: KNOWN_HOST = "xy.example.org"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_HOST = "xy.example.org";
test_class.type: String
test_class.var_name: KNOWN_HOST
test_class.declarator: KNOWN_PORT = 27777
test_class.modifier: private static final
test_class.original_string: private static final int KNOWN_PORT = 27777;
test_class.type: int
test_class.var_name: KNOWN_PORT
test_class.declarator: KNOWN_SERVER_ADDRESS = KNOWN_HOST + ":" + KNOWN_PORT
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_SERVER_ADDRESS = KNOWN_HOST + ":" + KNOWN_PORT;
test_class.type: String
test_class.var_name: KNOWN_SERVER_ADDRESS
test_class.declarator: KNOWN_MAX_QUERY_TIME = Duration.ofSeconds(13)
test_class.modifier: private static final
test_class.original_string: private static final Duration KNOWN_MAX_QUERY_TIME = Duration.ofSeconds(13);
test_class.type: Duration
test_class.var_name: KNOWN_MAX_QUERY_TIME
test_class.declarator: CONFIG = ConfigFactory.load("test")
test_class.modifier: private static final
test_class.original_string: private static final Config CONFIG = ConfigFactory.load("test");
test_class.type: Config
test_class.var_name: CONFIG
test_class.declarator: MONGO_URI_CONFIG_KEY = "mongodb.uri"
test_class.modifier: private static final
test_class.original_string: private static final String MONGO_URI_CONFIG_KEY = "mongodb.uri";
test_class.type: String
test_class.var_name: MONGO_URI_CONFIG_KEY
test_class.declarator: MONGO_SSL_CONFIG_KEY = "mongodb.options.ssl"
test_class.modifier: private static final
test_class.original_string: private static final String MONGO_SSL_CONFIG_KEY = "mongodb.options.ssl";
test_class.type: String
test_class.var_name: MONGO_SSL_CONFIG_KEY
test_class.declarator: MONGO_MAX_QUERY_TIME_CONFIG_KEY = "mongodb.maxQueryTime"
test_class.modifier: private static final
test_class.original_string: private static final String MONGO_MAX_QUERY_TIME_CONFIG_KEY = "mongodb.maxQueryTime";
test_class.type: String
test_class.var_name: MONGO_MAX_QUERY_TIME_CONFIG_KEY
test_class.file: services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/MongoClientWrapperTest.java
test_class.identifier: MongoClientWrapperTest
test_case.body: @Test
      public void createByUriWithSslEnabled() {
          // prepare
          final String uriWithSslEnabled = createUri(true);
          final Config config = CONFIG.withValue(MONGO_URI_CONFIG_KEY, ConfigValueFactory.fromAnyRef(uriWithSslEnabled));
          final DefaultMongoDbConfig mongoDbConfig = DefaultMongoDbConfig.of(config);
  
          // test
          final MongoClientWrapper underTest = MongoClientWrapper.newInstance(mongoDbConfig);
  
          // verify
          assertWithExpected(underTest, true, true);
      }
test_case.class_method_signature: MongoClientWrapperTest.createByUriWithSslEnabled()
test_case.full_signature: @Test public void createByUriWithSslEnabled()
test_case.identifier: createByUriWithSslEnabled
test_case.invocations: createUri withValue fromAnyRef of newInstance assertWithExpected
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void createByUriWithSslEnabled()
focal_class.declarator: mongoClient
focal_class.modifier: private final
focal_class.original_string: private final MongoClient mongoClient;
focal_class.type: MongoClient
focal_class.var_name: mongoClient
focal_class.declarator: defaultDatabase
focal_class.modifier: private final
focal_class.original_string: private final MongoDatabase defaultDatabase;
focal_class.type: MongoDatabase
focal_class.var_name: defaultDatabase
focal_class.declarator: dittoMongoClientSettings
focal_class.modifier: private final
focal_class.original_string: private final DittoMongoClientSettings dittoMongoClientSettings;
focal_class.type: DittoMongoClientSettings
focal_class.var_name: dittoMongoClientSettings
focal_class.declarator: eventLoopGroup
focal_class.modifier: @Nullable private final
focal_class.original_string: @Nullable private final EventLoopGroup eventLoopGroup;
focal_class.type: EventLoopGroup
focal_class.var_name: eventLoopGroup
focal_class.file: services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/MongoClientWrapper.java
focal_class.identifier: MongoClientWrapper
focal_class.interfaces: implements DittoMongoClient
focal_class.class_method_signature: MongoClientWrapper.MongoClientWrapper(final MongoClient theMongoClient,
              final String defaultDatabaseName,
              final DittoMongoClientSettings theDittoMongoClientSettings,
              @Nullable final EventLoopGroup theEventLoopGroup)
focal_class.full_signature: private  MongoClientWrapper(final MongoClient theMongoClient,
              final String defaultDatabaseName,
              final DittoMongoClientSettings theDittoMongoClientSettings,
              @Nullable final EventLoopGroup theEventLoopGroup)
focal_class.identifier: MongoClientWrapper
focal_class.modifiers: private
focal_class.parameters: (final MongoClient theMongoClient,
              final String defaultDatabaseName,
              final DittoMongoClientSettings theDittoMongoClientSettings,
              @Nullable final EventLoopGroup theEventLoopGroup)
focal_class.signature:  MongoClientWrapper(final MongoClient theMongoClient,
              final String defaultDatabaseName,
              final DittoMongoClientSettings theDittoMongoClientSettings,
              @Nullable final EventLoopGroup theEventLoopGroup)
focal_class.class_method_signature: MongoClientWrapper.newInstance(final MongoDbConfig mongoDbConfig)
focal_class.full_signature: public static MongoClientWrapper newInstance(final MongoDbConfig mongoDbConfig)
focal_class.identifier: newInstance
focal_class.modifiers: public static
focal_class.parameters: (final MongoDbConfig mongoDbConfig)
focal_class.return: MongoClientWrapper
focal_class.signature: MongoClientWrapper newInstance(final MongoDbConfig mongoDbConfig)
focal_class.class_method_signature: MongoClientWrapper.getBuilder()
focal_class.full_signature: public static DittoMongoClientBuilder.ConnectionCoordinatesStep getBuilder()
focal_class.identifier: getBuilder
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: DittoMongoClientBuilder.ConnectionCoordinatesStep
focal_class.signature: DittoMongoClientBuilder.ConnectionCoordinatesStep getBuilder()
focal_class.class_method_signature: MongoClientWrapper.getBuilder(final MongoDbConfig mongoDbConfig)
focal_class.full_signature: public static DittoMongoClientBuilder.GeneralPropertiesStep getBuilder(final MongoDbConfig mongoDbConfig)
focal_class.identifier: getBuilder
focal_class.modifiers: public static
focal_class.parameters: (final MongoDbConfig mongoDbConfig)
focal_class.return: DittoMongoClientBuilder.GeneralPropertiesStep
focal_class.signature: DittoMongoClientBuilder.GeneralPropertiesStep getBuilder(final MongoDbConfig mongoDbConfig)
focal_class.class_method_signature: MongoClientWrapper.getDefaultDatabase()
focal_class.full_signature: @Override public MongoDatabase getDefaultDatabase()
focal_class.identifier: getDefaultDatabase
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: MongoDatabase
focal_class.signature: MongoDatabase getDefaultDatabase()
focal_class.class_method_signature: MongoClientWrapper.getCollection(final CharSequence name)
focal_class.full_signature: @Override public MongoCollection<Document> getCollection(final CharSequence name)
focal_class.identifier: getCollection
focal_class.modifiers: @Override public
focal_class.parameters: (final CharSequence name)
focal_class.return: MongoCollection<Document>
focal_class.signature: MongoCollection<Document> getCollection(final CharSequence name)
focal_class.class_method_signature: MongoClientWrapper.getDittoSettings()
focal_class.full_signature: @Override public DittoMongoClientSettings getDittoSettings()
focal_class.identifier: getDittoSettings
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: DittoMongoClientSettings
focal_class.signature: DittoMongoClientSettings getDittoSettings()
focal_class.class_method_signature: MongoClientWrapper.getDatabase(final String name)
focal_class.full_signature: @Override public MongoDatabase getDatabase(final String name)
focal_class.identifier: getDatabase
focal_class.modifiers: @Override public
focal_class.parameters: (final String name)
focal_class.return: MongoDatabase
focal_class.signature: MongoDatabase getDatabase(final String name)
focal_class.class_method_signature: MongoClientWrapper.getSettings()
focal_class.full_signature: @Override @Deprecated public com.mongodb.async.client.MongoClientSettings getSettings()
focal_class.identifier: getSettings
focal_class.modifiers: @Override @Deprecated public
focal_class.parameters: ()
focal_class.return: com.mongodb.async.client.MongoClientSettings
focal_class.signature: com.mongodb.async.client.MongoClientSettings getSettings()
focal_class.class_method_signature: MongoClientWrapper.listDatabaseNames()
focal_class.full_signature: @Override public Publisher<String> listDatabaseNames()
focal_class.identifier: listDatabaseNames
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Publisher<String>
focal_class.signature: Publisher<String> listDatabaseNames()
focal_class.class_method_signature: MongoClientWrapper.listDatabaseNames(final ClientSession clientSession)
focal_class.full_signature: @Override public Publisher<String> listDatabaseNames(final ClientSession clientSession)
focal_class.identifier: listDatabaseNames
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSession clientSession)
focal_class.return: Publisher<String>
focal_class.signature: Publisher<String> listDatabaseNames(final ClientSession clientSession)
focal_class.class_method_signature: MongoClientWrapper.listDatabases()
focal_class.full_signature: @Override public ListDatabasesPublisher<Document> listDatabases()
focal_class.identifier: listDatabases
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ListDatabasesPublisher<Document>
focal_class.signature: ListDatabasesPublisher<Document> listDatabases()
focal_class.class_method_signature: MongoClientWrapper.listDatabases(final Class<TResult> clazz)
focal_class.full_signature: @Override public ListDatabasesPublisher<TResult> listDatabases(final Class<TResult> clazz)
focal_class.identifier: listDatabases
focal_class.modifiers: @Override public
focal_class.parameters: (final Class<TResult> clazz)
focal_class.return: ListDatabasesPublisher<TResult>
focal_class.signature: ListDatabasesPublisher<TResult> listDatabases(final Class<TResult> clazz)
focal_class.class_method_signature: MongoClientWrapper.listDatabases(final ClientSession clientSession)
focal_class.full_signature: @Override public ListDatabasesPublisher<Document> listDatabases(final ClientSession clientSession)
focal_class.identifier: listDatabases
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSession clientSession)
focal_class.return: ListDatabasesPublisher<Document>
focal_class.signature: ListDatabasesPublisher<Document> listDatabases(final ClientSession clientSession)
focal_class.class_method_signature: MongoClientWrapper.listDatabases(final ClientSession clientSession,
              final Class<TResult> clazz)
focal_class.full_signature: @Override public ListDatabasesPublisher<TResult> listDatabases(final ClientSession clientSession,
              final Class<TResult> clazz)
focal_class.identifier: listDatabases
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSession clientSession,
              final Class<TResult> clazz)
focal_class.return: ListDatabasesPublisher<TResult>
focal_class.signature: ListDatabasesPublisher<TResult> listDatabases(final ClientSession clientSession,
              final Class<TResult> clazz)
focal_class.class_method_signature: MongoClientWrapper.watch()
focal_class.full_signature: @Override public ChangeStreamPublisher<Document> watch()
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ChangeStreamPublisher<Document>
focal_class.signature: ChangeStreamPublisher<Document> watch()
focal_class.class_method_signature: MongoClientWrapper.watch(final Class<TResult> tResultClass)
focal_class.full_signature: @Override public ChangeStreamPublisher<TResult> watch(final Class<TResult> tResultClass)
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: (final Class<TResult> tResultClass)
focal_class.return: ChangeStreamPublisher<TResult>
focal_class.signature: ChangeStreamPublisher<TResult> watch(final Class<TResult> tResultClass)
focal_class.class_method_signature: MongoClientWrapper.watch(final List<? extends Bson> pipeline)
focal_class.full_signature: @Override public ChangeStreamPublisher<Document> watch(final List<? extends Bson> pipeline)
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: (final List<? extends Bson> pipeline)
focal_class.return: ChangeStreamPublisher<Document>
focal_class.signature: ChangeStreamPublisher<Document> watch(final List<? extends Bson> pipeline)
focal_class.class_method_signature: MongoClientWrapper.watch(final List<? extends Bson> pipeline,
              final Class<TResult> tResultClass)
focal_class.full_signature: @Override public ChangeStreamPublisher<TResult> watch(final List<? extends Bson> pipeline,
              final Class<TResult> tResultClass)
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: (final List<? extends Bson> pipeline,
              final Class<TResult> tResultClass)
focal_class.return: ChangeStreamPublisher<TResult>
focal_class.signature: ChangeStreamPublisher<TResult> watch(final List<? extends Bson> pipeline,
              final Class<TResult> tResultClass)
focal_class.class_method_signature: MongoClientWrapper.watch(final ClientSession clientSession)
focal_class.full_signature: @Override public ChangeStreamPublisher<Document> watch(final ClientSession clientSession)
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSession clientSession)
focal_class.return: ChangeStreamPublisher<Document>
focal_class.signature: ChangeStreamPublisher<Document> watch(final ClientSession clientSession)
focal_class.class_method_signature: MongoClientWrapper.watch(final ClientSession clientSession,
              final Class<TResult> tResultClass)
focal_class.full_signature: @Override public ChangeStreamPublisher<TResult> watch(final ClientSession clientSession,
              final Class<TResult> tResultClass)
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSession clientSession,
              final Class<TResult> tResultClass)
focal_class.return: ChangeStreamPublisher<TResult>
focal_class.signature: ChangeStreamPublisher<TResult> watch(final ClientSession clientSession,
              final Class<TResult> tResultClass)
focal_class.class_method_signature: MongoClientWrapper.watch(final ClientSession clientSession,
              final List<? extends Bson> pipeline)
focal_class.full_signature: @Override public ChangeStreamPublisher<Document> watch(final ClientSession clientSession,
              final List<? extends Bson> pipeline)
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSession clientSession,
              final List<? extends Bson> pipeline)
focal_class.return: ChangeStreamPublisher<Document>
focal_class.signature: ChangeStreamPublisher<Document> watch(final ClientSession clientSession,
              final List<? extends Bson> pipeline)
focal_class.class_method_signature: MongoClientWrapper.watch(final ClientSession clientSession,
              final List<? extends Bson> pipeline, final Class<TResult> tResultClass)
focal_class.full_signature: @Override public ChangeStreamPublisher<TResult> watch(final ClientSession clientSession,
              final List<? extends Bson> pipeline, final Class<TResult> tResultClass)
focal_class.identifier: watch
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSession clientSession,
              final List<? extends Bson> pipeline, final Class<TResult> tResultClass)
focal_class.return: ChangeStreamPublisher<TResult>
focal_class.signature: ChangeStreamPublisher<TResult> watch(final ClientSession clientSession,
              final List<? extends Bson> pipeline, final Class<TResult> tResultClass)
focal_class.class_method_signature: MongoClientWrapper.startSession()
focal_class.full_signature: @Override public Publisher<ClientSession> startSession()
focal_class.identifier: startSession
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Publisher<ClientSession>
focal_class.signature: Publisher<ClientSession> startSession()
focal_class.class_method_signature: MongoClientWrapper.startSession(final ClientSessionOptions options)
focal_class.full_signature: @Override public Publisher<ClientSession> startSession(final ClientSessionOptions options)
focal_class.identifier: startSession
focal_class.modifiers: @Override public
focal_class.parameters: (final ClientSessionOptions options)
focal_class.return: Publisher<ClientSession>
focal_class.signature: Publisher<ClientSession> startSession(final ClientSessionOptions options)
focal_class.class_method_signature: MongoClientWrapper.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_method.body: public static MongoClientWrapper newInstance(final MongoDbConfig mongoDbConfig) {
          return (MongoClientWrapper) getBuilder(mongoDbConfig).build();
      }
focal_method.class_method_signature: MongoClientWrapper.newInstance(final MongoDbConfig mongoDbConfig)
focal_method.full_signature: public static MongoClientWrapper newInstance(final MongoDbConfig mongoDbConfig)
focal_method.identifier: newInstance
focal_method.invocations: build getBuilder
focal_method.modifiers: public static
focal_method.parameters: (final MongoDbConfig mongoDbConfig)
focal_method.return: MongoClientWrapper
focal_method.signature: MongoClientWrapper newInstance(final MongoDbConfig mongoDbConfig)