Index: activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java
===================================================================
--- activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java    (revision 649617)
+++ activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java    (working copy)
@@ -79,8 +79,7 @@
             ReferenceRecord record) throws Exception {
         MessageId id = new MessageId(record.getMessageId());
         if (listener.hasSpace()) {
-            listener.recoverMessageReference(id);
-            return true;
+            return listener.recoverMessageReference(id);
         }
         return false;
     }