diff --git a/src/main/java/io/autoinvestor/infrastructure/repositories/MongoAssetRepository.java b/src/main/java/io/autoinvestor/infrastructure/repositories/MongoAssetRepository.java index 01ebd33..6d85c2a 100644 --- a/src/main/java/io/autoinvestor/infrastructure/repositories/MongoAssetRepository.java +++ b/src/main/java/io/autoinvestor/infrastructure/repositories/MongoAssetRepository.java @@ -41,7 +41,10 @@ public boolean exists(String mic, String ticker) { @Override public Optional findById(AssetId assetId) { - return Optional.ofNullable(template.findById(assetId.value(), AssetDocument.class)) + String id = assetId.value(); + var q = Query.query(Criteria.where("_id").is(id)); + AssetDocument doc = template.findOne(q, AssetDocument.class); + return Optional.ofNullable(doc) .map(mapper::toDomain); }