This is an automated email from the ASF dual-hosted git repository. zhouxzhan pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit d2a4b7047659793534b0c9e5f7335580ece53152 Author: nowinkey <[email protected]> AuthorDate: Thu Feb 9 10:46:31 2023 +0800 Change the permission modifier of reputFromOffset from public to protected --- store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index dedab1101..788f1d6d6 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -2665,7 +2665,7 @@ public class DefaultMessageStore implements MessageStore { class ReputMessageService extends ServiceThread { - public volatile long reputFromOffset = 0; + protected volatile long reputFromOffset = 0; public long getReputFromOffset() { return reputFromOffset;
