Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

This commit is contained in:
Robbie Gemmell 2023-08-29 10:07:32 +01:00
parent df410da7ae
commit c1648d5917
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/caches/LocalCache.java
View File

@ -27,6 +27,7 @@ import java.lang.invoke.MethodHandles;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
public class LocalCache implements Cache, RemovalListener<String, String> { public class LocalCache implements Cache, RemovalListener<String, String> {
@ -70,7 +71,7 @@ public class LocalCache implements Cache, RemovalListener<String, String> {
@Override @Override
public void start() { public void start() {
if (persisted) { if (persisted) {
persistedCacheEntries = storageManager.getPersistedKeyValuePairs(id); persistedCacheEntries = new ConcurrentHashMap<>(storageManager.getPersistedKeyValuePairs(id));
if (persistedCacheEntries != null) { if (persistedCacheEntries != null) {
for (Map.Entry<String, PersistedKeyValuePair> cacheEntry : persistedCacheEntries.entrySet()) { for (Map.Entry<String, PersistedKeyValuePair> cacheEntry : persistedCacheEntries.entrySet()) {