diff --git a/src/main/java/com/knecon/fforesight/mongo/database/commons/service/MongoClientCache.java b/src/main/java/com/knecon/fforesight/mongo/database/commons/service/MongoClientCache.java index 0e3b1cf..6070d72 100644 --- a/src/main/java/com/knecon/fforesight/mongo/database/commons/service/MongoClientCache.java +++ b/src/main/java/com/knecon/fforesight/mongo/database/commons/service/MongoClientCache.java @@ -43,7 +43,7 @@ public class MongoClientCache { var mongoDBConnection = mongoConnectionProvider.getMongoDBConnection(key); if (mongoDBConnection != null) { - return new MongoClientConnection(key, buildMongoClient(mongoDBConnection)); + return new MongoClientConnection(mongoDBConnection.getDatabase(), buildMongoClient(mongoDBConnection)); } throw new RuntimeException("No Connection provided"); }