ARTEMIS-4406: update LocalCache persisted entry tracking to use a Con…

…currentHashMap
apache · Aug 29, 2023 · c1648d5 · c1648d5
1 parent df410da
commit c1648d5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...rver/src/main/java/org/apache/activemq/artemis/core/server/routing/caches/LocalCache.java b/...rver/src/main/java/org/apache/activemq/artemis/core/server/routing/caches/LocalCache.java
@@ -27,6 +27,7 @@
 
 import java.util.Map;
 import java.util.Objects;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
 
 public class LocalCache implements Cache, RemovalListener<String, String> {
@@ -70,7 +71,7 @@ public LocalCache(String id, boolean persisted, int timeout, StorageManager stor
    @Override
    public void start() {
       if (persisted) {
-         persistedCacheEntries = storageManager.getPersistedKeyValuePairs(id);
+         persistedCacheEntries = new ConcurrentHashMap<>(storageManager.getPersistedKeyValuePairs(id));
 
          if (persistedCacheEntries != null) {
             for (Map.Entry<String, PersistedKeyValuePair> cacheEntry : persistedCacheEntries.entrySet()) {