Bugfix: Use a thread-safe version of the map for caching the MongoCol…

…lection handle (#219)
hypertrace · Jan 29, 2025 · a3fa786 · a3fa786
1 parent c2eec6d
commit a3fa786
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ava/org/hypertrace/core/documentstore/mongo/collection/MongoCollectionOptionsApplier.java b/...ava/org/hypertrace/core/documentstore/mongo/collection/MongoCollectionOptionsApplier.java
@@ -6,8 +6,8 @@
 import com.mongodb.BasicDBObject;
 import com.mongodb.ReadPreference;
 import com.mongodb.client.MongoCollection;
-import java.util.HashMap;
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 import lombok.Builder;
 import lombok.Value;
 import lombok.experimental.Accessors;
@@ -18,7 +18,7 @@ public class MongoCollectionOptionsApplier {
   private final Map<CacheKey, MongoCollection<BasicDBObject>> collectionCache;
 
   public MongoCollectionOptionsApplier() {
-    this.collectionCache = new HashMap<>();
+    this.collectionCache = new ConcurrentHashMap<>();
   }
 
   public MongoCollection<BasicDBObject> applyOptions(