Skip to content

Commit 9fcb0b6

Browse files
committed
add WriteConcern.JOURNALED to ensure that write all data before closing.
1 parent dcc204f commit 9fcb0b6

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

plugins/mongodbplugin/src/main/java/org/tron/mongodb/MongoManager.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import com.mongodb.MongoClientOptions;
55
import com.mongodb.MongoCredential;
66
import com.mongodb.ServerAddress;
7+
import com.mongodb.WriteConcern;
78
import com.mongodb.client.MongoDatabase;
89
import com.mongodb.client.model.IndexOptions;
910
import com.mongodb.client.model.Indexes;
@@ -33,6 +34,7 @@ public void initConfig(MongoConfig config) {
3334
config.getThreadsAllowedToBlockForConnectionMultiplier();
3435
MongoClientOptions options = MongoClientOptions.builder().connectionsPerHost(connectionsPerHost)
3536
.threadsAllowedToBlockForConnectionMultiplier(threadsAllowedToBlockForConnectionMultiplier)
37+
.writeConcern(WriteConcern.JOURNALED)
3638
.build();
3739

3840
String host = config.getHost();

0 commit comments

Comments
 (0)