diff --git a/activemq-core/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java b/activemq-core/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
index 0f01c4e8e2..0239edd371 100644
--- a/activemq-core/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
@@ -56,6 +56,7 @@ public class SlowConsumerTest extends TestCase {
         final BrokerService broker = new BrokerService();
         broker.setPersistent(true);
         broker.setUseJmx(true);
+        broker.setDeleteAllMessagesOnStartup(true);
 
         broker.addConnector("tcp://localhost:61616").setName("Default");
         broker.start();