diff --git a/src/org/redkale/mq/MessageRecord.java b/src/org/redkale/mq/MessageRecord.java
index e6ed72ad0..d70e1d09c 100644
--- a/src/org/redkale/mq/MessageRecord.java
+++ b/src/org/redkale/mq/MessageRecord.java
@@ -135,6 +135,11 @@ public class MessageRecord implements Serializable {
         return this.resptopic == null || this.resptopic.isEmpty();
     }
 
+    public <T> T convertFromContent(Convert convert, java.lang.reflect.Type type) {
+        if (this.content == null || this.content.length == 0) return null;
+        return (T) convert.convertFrom(type, this.content);
+    }
+
     public MessageRecord version(int version) {
         this.version = version;
         return this;