16
16
17
17
package com.mongodb.internal.connection
18
18
19
+ import com.mongodb.LoggerSettings
19
20
import com.mongodb.MongoSocketOpenException
20
21
import com.mongodb.MongoSocketReadTimeoutException
21
22
import com.mongodb.OperationFunctionalSpecification
@@ -52,7 +53,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
52
53
given :
53
54
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
54
55
new AsynchronousSocketChannelStreamFactory (openSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
55
- [], null , getServerApi())
56
+ [], LoggerSettings . builder() . build(), null , getServerApi())
56
57
.create(new ServerId (new ClusterId (), new ServerAddress (new InetSocketAddress (' 192.168.255.255' , 27017 ))))
57
58
58
59
when :
@@ -67,7 +68,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
67
68
given :
68
69
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
69
70
new AsynchronousSocketChannelStreamFactory (readSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
70
- [], null , getServerApi()). create(new ServerId (new ClusterId (), getPrimary()))
71
+ [], LoggerSettings . builder() . build(), null , getServerApi()). create(new ServerId (new ClusterId (), getPrimary()))
71
72
connection. open()
72
73
73
74
getCollectionHelper(). insertDocuments(new BsonDocument (' _id' , new BsonInt32 (1 )))
@@ -88,7 +89,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
88
89
given :
89
90
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
90
91
new NettyStreamFactory (openSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
91
- [], null , getServerApi()). create(new ServerId (new ClusterId (),
92
+ [], LoggerSettings . builder() . build(), null , getServerApi()). create(new ServerId (new ClusterId (),
92
93
new ServerAddress (new InetSocketAddress (' 192.168.255.255' , 27017 ))))
93
94
94
95
when :
@@ -103,7 +104,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
103
104
given :
104
105
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
105
106
new NettyStreamFactory (readSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
106
- [], null , getServerApi()). create(new ServerId (new ClusterId (), getPrimary()))
107
+ [], LoggerSettings . builder() . build(), null , getServerApi()). create(new ServerId (new ClusterId (), getPrimary()))
107
108
connection. open()
108
109
109
110
getCollectionHelper(). insertDocuments(new BsonDocument (' _id' , new BsonInt32 (1 )))
0 commit comments