From fcd69474a2d69aec56bb27de700f9214671cf71c Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Wed, 27 May 2020 15:22:41 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageRecord.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/org/redkale/mq/MessageRecord.java b/src/org/redkale/mq/MessageRecord.java
index d9b4e066b..8ced08b72 100644
--- a/src/org/redkale/mq/MessageRecord.java
+++ b/src/org/redkale/mq/MessageRecord.java
@@ -45,12 +45,12 @@ public class MessageRecord implements Serializable {
     public MessageRecord() {
     }
 
-    public MessageRecord(String resptopic, Convert convert, Object bean) {
-        this(System.nanoTime(), 0, 0, null, null, resptopic, convert.convertToBytes(bean));
+    public MessageRecord(String topic, String resptopic, Convert convert, Object bean) {
+        this(System.nanoTime(), 0, 0, null, topic, resptopic, convert.convertToBytes(bean));
     }
 
-    public MessageRecord(String resptopic, byte[] content) {
-        this(System.nanoTime(), 0, 0, null, null, resptopic, content);
+    public MessageRecord(String topic, String resptopic, byte[] content) {
+        this(System.nanoTime(), 0, 0, null, topic, resptopic, content);
     }
 
     public MessageRecord(long seqid, String topic, String resptopic, byte[] content) {