From ec4ec2ff77e63ec6bc50cc47ff4327804f6ce45d Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Tue, 26 May 2020 22:22:44 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageRecord.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/org/redkale/mq/MessageRecord.java b/src/org/redkale/mq/MessageRecord.java index ee6983ab5..adc295443 100644 --- a/src/org/redkale/mq/MessageRecord.java +++ b/src/org/redkale/mq/MessageRecord.java @@ -45,6 +45,10 @@ public class MessageRecord implements Serializable { public MessageRecord() { } + public MessageRecord(String resptopic, byte[] content) { + this(System.nanoTime(), 0, 0, null, null, resptopic, content); + } + public MessageRecord(long seqid, String topic, String resptopic, byte[] content) { this(seqid, 0, 0, null, topic, resptopic, content); } @@ -107,7 +111,7 @@ public class MessageRecord implements Serializable { return this; } - public MessageRecord contentUTF8(String content) { + public MessageRecord contentUTF8String(String content) { this.content = content == null ? null : content.getBytes(StandardCharsets.UTF_8); return this; }