Skip to content

Commit

Permalink
Fix Spock tests
Browse files Browse the repository at this point in the history
  • Loading branch information
jyemin committed Feb 1, 2023
1 parent 56582e9 commit 6c72680
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@

package com.mongodb.internal.connection

import com.mongodb.LoggerSettings
import com.mongodb.MongoSocketOpenException
import com.mongodb.MongoSocketReadTimeoutException
import com.mongodb.OperationFunctionalSpecification
Expand Down Expand Up @@ -52,7 +53,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
given:
def connection = new InternalStreamConnectionFactory(ClusterConnectionMode.SINGLE,
new AsynchronousSocketChannelStreamFactory(openSocketSettings, getSslSettings()), getCredentialWithCache(), null, null,
[], null, getServerApi())
[], LoggerSettings.builder().build(), null, getServerApi())
.create(new ServerId(new ClusterId(), new ServerAddress(new InetSocketAddress('192.168.255.255', 27017))))

when:
Expand All @@ -67,7 +68,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
given:
def connection = new InternalStreamConnectionFactory(ClusterConnectionMode.SINGLE,
new AsynchronousSocketChannelStreamFactory(readSocketSettings, getSslSettings()), getCredentialWithCache(), null, null,
[], null, getServerApi()).create(new ServerId(new ClusterId(), getPrimary()))
[], LoggerSettings.builder().build(), null, getServerApi()).create(new ServerId(new ClusterId(), getPrimary()))
connection.open()

getCollectionHelper().insertDocuments(new BsonDocument('_id', new BsonInt32(1)))
Expand All @@ -88,7 +89,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
given:
def connection = new InternalStreamConnectionFactory(ClusterConnectionMode.SINGLE,
new NettyStreamFactory(openSocketSettings, getSslSettings()), getCredentialWithCache(), null, null,
[], null, getServerApi()).create(new ServerId(new ClusterId(),
[], LoggerSettings.builder().build(), null, getServerApi()).create(new ServerId(new ClusterId(),
new ServerAddress(new InetSocketAddress('192.168.255.255', 27017))))

when:
Expand All @@ -103,7 +104,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
given:
def connection = new InternalStreamConnectionFactory(ClusterConnectionMode.SINGLE,
new NettyStreamFactory(readSocketSettings, getSslSettings()), getCredentialWithCache(), null, null,
[], null, getServerApi()).create(new ServerId(new ClusterId(), getPrimary()))
[], LoggerSettings.builder().build(), null, getServerApi()).create(new ServerId(new ClusterId(), getPrimary()))
connection.open()

getCollectionHelper().insertDocuments(new BsonDocument('_id', new BsonInt32(1)))
Expand Down

0 comments on commit 6c72680

Please sign in to comment.