address comment

315157973 · Feb 20, 2024 · 5eb2ba6 · 5eb2ba6
1 parent 2a89499
commit 5eb2ba6
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java b/...main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
@@ -105,9 +105,9 @@ public boolean expireMessages(int messageTTLInSeconds) {
         }
     }
 
-    private boolean checkExpiryByLedgerClosureTime(ManagedCursor cursor, int messageTTLInSeconds) {
+    private void checkExpiryByLedgerClosureTime(ManagedCursor cursor, int messageTTLInSeconds) {
         if (messageTTLInSeconds <= 0) {
-            return false;
+            return;
         }
         if (cursor instanceof ManagedCursorImpl managedCursor) {
             ManagedLedgerImpl managedLedger = (ManagedLedgerImpl) managedCursor.getManagedLedger();
@@ -130,10 +130,8 @@ private boolean checkExpiryByLedgerClosureTime(ManagedCursor cursor, int message
                 } else {
                     findEntryComplete(position, null);
                 }
-                return true;
             }
         }
-        return false;
     }
 
     @Override