diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistentAdaptor.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistentAdaptor.java
index 318c409ef3..794f9767d1 100755
--- a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistentAdaptor.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistentAdaptor.java
@@ -117,7 +117,9 @@ public class KahaPersistentAdaptor implements PersistenceAdapter{
 
     public void start() throws Exception{}
 
-    public void stop() throws Exception{}
+    public void stop() throws Exception{
+        store.close();
+    }
 
     public long getLastMessageBrokerSequenceId() throws IOException{
         return 0;