public class ExternalMongoConnector extends java.lang.Object implements MongoConnector
MongoConnector that doesn't own the lifecycle of MongoClient.| Constructor and Description |
|---|
ExternalMongoConnector(com.mongodb.WriteConcern writeConcern,
com.mongodb.client.MongoClient mongoClient,
java.lang.String dbName)
Constructs an instance of
ExternalMongoConnector. |
ExternalMongoConnector(com.mongodb.WriteConcern writeConcern,
com.mongodb.client.MongoDatabase database)
Constructs an instance of
ExternalMongoConnector. |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Quartz-mongodb will call this method when shutting down.
|
com.mongodb.client.MongoCollection<org.bson.Document> |
getCollection(java.lang.String collectionName)
Quartz-mongodb will call this method to get the instance of
MongoCollection for internal uses. |
public ExternalMongoConnector(com.mongodb.WriteConcern writeConcern,
com.mongodb.client.MongoDatabase database)
ExternalMongoConnector.writeConcern - instance of WriteConcern. Each MongoCollection produced by
getCollection(String) will be configured with this write concern.database - MongoDatabase instance. Will be used to produce collections.public ExternalMongoConnector(com.mongodb.WriteConcern writeConcern,
com.mongodb.client.MongoClient mongoClient,
java.lang.String dbName)
ExternalMongoConnector.writeConcern - instance of WriteConcern. Each MongoCollection produced by
getCollection(String) will be configured with this write concern.mongoClient - instance of MongoClient.dbName - name of the database that will be used to produce collections.public com.mongodb.client.MongoCollection<org.bson.Document> getCollection(java.lang.String collectionName)
MongoConnectorMongoCollection for internal uses.
The collection is expected to be fully configured with correct WriteConcern.getCollection in interface MongoConnectorcollectionName - collection name.MongoCollection.public void close()
MongoConnectorMongoClient here.close in interface MongoConnectorclose in interface java.io.Closeableclose in interface java.lang.AutoCloseable