lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-05-27 15:22:41 +08:00
parent 3130e00bab
commit fcd69474a2
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/org/redkale/mq/MessageRecord.java
View File

@@ -45,12 +45,12 @@ public class MessageRecord implements Serializable {
public MessageRecord() { public MessageRecord() {
} }
public MessageRecord(String resptopic, Convert convert, Object bean) { public MessageRecord(String topic, String resptopic, Convert convert, Object bean) {
this(System.nanoTime(), 0, 0, null, null, resptopic, convert.convertToBytes(bean)); this(System.nanoTime(), 0, 0, null, topic, resptopic, convert.convertToBytes(bean));
} }
public MessageRecord(String resptopic, byte[] content) { public MessageRecord(String topic, String resptopic, byte[] content) {
this(System.nanoTime(), 0, 0, null, null, resptopic, content); this(System.nanoTime(), 0, 0, null, topic, resptopic, content);
} }
public MessageRecord(long seqid, String topic, String resptopic, byte[] content) { public MessageRecord(long seqid, String topic, String resptopic, byte[] content) {