diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java
index d70be68523..61129f6f48 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java
@@ -270,6 +270,7 @@ class HashBin {
         HashPageInfo info = hashPages.get(pageNo);
         if (info.size() > maximumEntries) {
             // overflowed
+            info.begin();
             HashEntry entry = info.removeHashEntry(info.size() - 1);
             doOverFlow(pageNo + 1, entry);
         }