diff --git a/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java b/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java index f5b7ac6c53890a93727673f3c029534a81ae6b18..a4a3aac0057ef3a8422498f6eaa23ab499ea3b7e 100644 --- a/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java +++ b/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java @@ -16,19 +16,30 @@ */ package org.apache.rocketmq.store.pop; +import com.alibaba.fastjson.annotation.JSONField; import java.util.ArrayList; import java.util.List; public class PopCheckPoint { + @JSONField(name = "so") private long startOffset; + @JSONField(name = "pt") private long popTime; + @JSONField(name = "it") private long invisibleTime; + @JSONField(name = "bm") private int bitMap; + @JSONField(name = "n") private byte num; + @JSONField(name = "q") private byte queueId; + @JSONField(name = "t") private String topic; + @JSONField(name = "c") private String cid; + @JSONField(name = "ro") private long reviveOffset; + @JSONField(name = "d") private List queueOffsetDiff; public long getReviveOffset() {