diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
index 59da7a672e..dd81e75950 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
@@ -56,6 +56,7 @@ class QueueStorePrefetch extends AbstractPendingMessageCursor implements Message
     }
 
     public void start() throws Exception {
+        store.resetBatching();
     }
 
     public void stop() throws Exception {