commit eadd10cd928c8daad27024a3e616bef475a4002f
author pingww <pingw002@gmail.com> Thu Jan 19 10:09:05 2023 +0800
committer GitHub <noreply@github.com> Thu Jan 19 10:09:05 2023 +0800
tree 772e7508a9b142ef94fbea9a23378c83071b0d60
parent 3d869af5123781259c3d321061ef9737786b7a9e
parent 3c93fcb843010b63d22a8a57a5dd2ac6259cb6b6

Merge pull request #176 from pingww/main

clean offset

mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java

diff --git a/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java b/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java
index d37dd99..560fc52 100644
--- a/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java
+++ b/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java
@@ -523,6 +523,9 @@
     private void persistAllOffset(boolean needSleep) {
         try {
             for (Session session : sessionMap.values()) {
+                if (session.isClean()) {
+                    continue;
+                }
                 if (persistOffset(session) && needSleep) {
                     Thread.sleep(5L);
                 }
@@ -534,6 +537,9 @@
 
     private boolean persistOffset(Session session) {
         try {
+            if (session.isClean()) {
+                return true;
+            }
             if (!session.getPersistOffsetFlag()) {
                 return false;
             }