Skip to content

Commit 69f5f6b

Browse files
committed
Fixes couchbase factory
1 parent 66b4333 commit 69f5f6b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

couchbase-driver/src/main/java/org/jnosql/diana/couchbase/document/CouhbaseDocumentCollectionManagerFactory.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public class CouhbaseDocumentCollectionManagerFactory implements DocumentCollect
4141

4242
@Override
4343
public CouchbaseDocumentCollectionManagerAsync getAsync(String database) throws UnsupportedOperationException, NullPointerException {
44-
return new CouchbaseDocumentCollectionManagerAsync(get(database));
44+
return new DefaultCouchbaseDocumentCollectionManagerAsync(get(database));
4545
}
4646

4747
@Override
@@ -58,9 +58,9 @@ public CouchbaseDocumentCollectionManager get(String database) throws Unsupporte
5858
if (DEFAULT_BUCKET.equals(database)) {
5959
Bucket bucket = couchbaseCluster.openBucket(database);
6060
bucket.bucketManager().createN1qlPrimaryIndex(true, false);
61-
return new CouchbaseDocumentCollectionManager(bucket, database);
61+
return new DefaultCouchbaseDocumentCollectionManager(bucket, database);
6262
}
63-
return new CouchbaseDocumentCollectionManager(couchbaseCluster.openBucket(database, password), database);
63+
return new DefaultCouchbaseDocumentCollectionManager(couchbaseCluster.openBucket(database, password), database);
6464
}
6565

6666
@Override

0 commit comments

Comments
 (0)