Skip to content

Commit a3afd75

Browse files
committed
Fix test: add serverApi to command
JAVA-4228
1 parent fce49df commit a3afd75

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

driver-core/src/test/functional/com/mongodb/internal/operation/AsyncQueryBatchCursorFunctionalSpecification.groovy

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ import static com.mongodb.ClusterFixture.getBinding
5454
import static com.mongodb.ClusterFixture.getConnection
5555
import static com.mongodb.ClusterFixture.getReadConnectionSource
5656
import static com.mongodb.ClusterFixture.getReferenceCountAfterTimeout
57+
import static com.mongodb.ClusterFixture.getServerApi
5758
import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet
5859
import static com.mongodb.ClusterFixture.isSharded
5960
import static com.mongodb.ClusterFixture.serverVersionLessThan
@@ -380,7 +381,7 @@ class AsyncQueryBatchCursorFunctionalSpecification extends OperationFunctionalSp
380381
new BsonDocument('killCursors', new BsonString(namespace.getCollectionName()))
381382
.append('cursors', new BsonArray(singletonList(new BsonInt64(serverCursor.getId())))),
382383
new NoOpFieldNameValidator(), ReadPreference.primary(),
383-
new BsonDocumentCodec(), new NoOpSessionContext(), null)
384+
new BsonDocumentCodec(), new NoOpSessionContext(), getServerApi())
384385
}
385386
connection.release()
386387
nextBatch()

driver-core/src/test/functional/com/mongodb/internal/operation/QueryBatchCursorFunctionalSpecification.groovy

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ import java.util.concurrent.TimeUnit
4646

4747
import static com.mongodb.ClusterFixture.checkReferenceCountReachesTarget
4848
import static com.mongodb.ClusterFixture.getBinding
49+
import static com.mongodb.ClusterFixture.getServerApi
4950
import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet
5051
import static com.mongodb.ClusterFixture.isSharded
5152
import static com.mongodb.ClusterFixture.serverVersionAtLeast
@@ -533,7 +534,7 @@ class QueryBatchCursorFunctionalSpecification extends OperationFunctionalSpecifi
533534
new BsonDocument('killCursors', new BsonString(namespace.getCollectionName()))
534535
.append('cursors', new BsonArray(singletonList(new BsonInt64(serverCursor.getId())))),
535536
new NoOpFieldNameValidator(), ReadPreference.primary(),
536-
new BsonDocumentCodec(), new NoOpSessionContext(), null)
537+
new BsonDocumentCodec(), new NoOpSessionContext(), getServerApi())
537538
}
538539
connection.release()
539540
cursor.next()

0 commit comments

Comments
 (0)