From bf700aa88ff288219ab55d9160a1d9356698d579 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Sat, 30 May 2020 10:23:36 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageRecord.java | 5 +++++ 1 file changed, 5 insertions(+) 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 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;