Repository: activemq Updated Branches: refs/heads/master de24980a6 -> b52796f79
AMQ-5748 - replace Map with ConcurrentMap for JDK7 Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/b52796f7 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/b52796f7 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/b52796f7 Branch: refs/heads/master Commit: b52796f79405d45d582254df2e74516a512986f5 Parents: de24980 Author: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com> Authored: Fri Aug 7 17:54:35 2015 +0000 Committer: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com> Committed: Fri Aug 7 17:54:35 2015 +0000 ---------------------------------------------------------------------- .../java/org/apache/activemq/store/kahadb/MessageDatabase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/b52796f7/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java ---------------------------------------------------------------------- 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 533f0c2..5a36da1 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<String, MessageStore> storeCache = + protected final ConcurrentMap<String, MessageStore> storeCache = new ConcurrentHashMap<String, MessageStore>(); /**
