diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
index 0357d28fd5..85b6751156 100644
--- a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
@@ -161,7 +161,7 @@ public class KahaPersistenceAdapter implements PersistenceAdapter{
 
     public void deleteAllMessages() throws IOException{
         if(theStore!=null){
-            theStore.clear();
+            theStore.delete();
         }
     }