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<String, MessageStore> storeCache =
+    protected final ConcurrentMap<String, MessageStore> storeCache =
             new ConcurrentHashMap<String, MessageStore>();
 
     /**