diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRef.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRef.java
index 4bbbb64e49..65e9735078 100644
--- a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRef.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRef.java
@@ -71,6 +71,10 @@ public class ConsumerMessageRef{
     public void setMessageId(MessageId messageId){
         this.messageId=messageId;
     }
+    
+    public String toString() {
+        return "ConsumerMessageRef[" + messageId +"]";
+    }
 
        
 }