Skip to content

Commit

Permalink
Fix read concern logging in MongoThingSearchPersistence.
Browse files Browse the repository at this point in the history
Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
  • Loading branch information
yufei-cai committed Jun 30, 2022
1 parent 572a351 commit ce41549
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -99,10 +99,10 @@ public final class MongoThingsSearchPersistence implements ThingsSearchPersisten
public MongoThingsSearchPersistence(final DittoMongoClient mongoClient, final ActorSystem actorSystem,
final SearchPersistenceConfig persistenceConfig) {
final MongoDatabase database = mongoClient.getDefaultDatabase();
final var readConcern = persistenceConfig.readConcern().getMongoReadConcern();
final var readConcern = persistenceConfig.readConcern();
final var readPreference = persistenceConfig.readPreference().getMongoReadPreference();
collection = database.getCollection(PersistenceConstants.THINGS_COLLECTION_NAME)
.withReadConcern(readConcern)
.withReadConcern(readConcern.getMongoReadConcern())
.withReadPreference(readPreference);
log = Logging.getLogger(actorSystem, getClass());
indexInitializer = IndexInitializer.of(database, SystemMaterializer.get(actorSystem).materializer());
Expand Down

0 comments on commit ce41549

Please sign in to comment.