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-26 19:11:12 +08:00
parent 53457b73ad
commit 5a1c9215bc
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -22,7 +22,7 @@ import org.redkale.util.Comment;
public class MessageRecord implements Serializable { public class MessageRecord implements Serializable {
@Comment("消息序列号") @Comment("消息序列号")
protected long seqno; protected long seqid;
@Comment("标记位, 自定义时使用") @Comment("标记位, 自定义时使用")
protected int flag; protected int flag;
@@ -45,16 +45,16 @@ public class MessageRecord implements Serializable {
public MessageRecord() { public MessageRecord() {
} }
public MessageRecord(long seqno, String topic, String resptopic, byte[] content) { public MessageRecord(long seqid, String topic, String resptopic, byte[] content) {
this(seqno, 0, 0, null, topic, resptopic, content); this(seqid, 0, 0, null, topic, resptopic, content);
} }
public MessageRecord(long seqno, int userid, String groupid, String topic, String resptopic, byte[] content) { public MessageRecord(long seqid, int userid, String groupid, String topic, String resptopic, byte[] content) {
this(seqno, 0, userid, groupid, topic, resptopic, content); this(seqid, 0, userid, groupid, topic, resptopic, content);
} }
public MessageRecord(long seqno, int flag, int userid, String groupid, String topic, String resptopic, byte[] content) { public MessageRecord(long seqid, int flag, int userid, String groupid, String topic, String resptopic, byte[] content) {
this.seqno = seqno; this.seqid = seqid;
this.flag = flag; this.flag = flag;
this.userid = userid; this.userid = userid;
this.groupid = groupid; this.groupid = groupid;
@@ -112,12 +112,12 @@ public class MessageRecord implements Serializable {
return this; return this;
} }
public long getSeqno() { public long getSeqid() {
return seqno; return seqid;
} }
public void setSeqno(long seqno) { public void setSeqid(long seqid) {
this.seqno = seqno; this.seqid = seqid;
} }
public int getFlag() { public int getFlag() {