From b52796f79405d45d582254df2e74516a512986f5 Mon Sep 17 00:00:00 2001 From: "Christopher L. Shannon (cshannon)" Date: Fri, 7 Aug 2015 17:54:35 +0000 Subject: [PATCH] AMQ-5748 - replace Map with ConcurrentMap for JDK7 --- .../java/org/apache/activemq/store/kahadb/MessageDatabase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java index 533f0c2f97..5a36da167c 100644 --- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java +++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java @@ -47,6 +47,7 @@ import java.util.SortedSet; import java.util.TreeMap; import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.locks.ReentrantReadWriteLock; @@ -2281,7 +2282,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe * This is a map to cache DestinationStatistics for a specific * KahaDestination key */ - protected final Map storeCache = + protected final ConcurrentMap storeCache = new ConcurrentHashMap(); /**