alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-167 Corrected the MongoUtil class

Browse Source 
Corrected the `onCollection` utility method in the `MongoUtil` class to pass in the collection name rather than the database name.
This commit is contained in:
Randall Hauch 2016-12-20 16:24:07 -06:00
parent d1d21166b9
commit c1a26ee261
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoUtil.java
View File

@ -125,7 +125,7 @@ public static void onCollection(MongoClient client, String dbName, String collec
Consumer<MongoCollection<Document>> collectionOperation) {
onDatabase(client, dbName, db -> {
if (contains(db.listCollectionNames(), collectionName)) {
collectionOperation.accept(db.getCollection(dbName));
collectionOperation.accept(db.getCollection(collectionName));
}
});
}