Merge branch 'dev' of https://gitee.com/noear/folkmq into dev

noear · Jan 17, 2024 · bc0bf67 · bc0bf67
2 parents 2ef1ad1 + e464570
commit bc0bf67
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/folkmq/src/main/java/org/noear/folkmq/server/MqQueueDefault.java b/folkmq/src/main/java/org/noear/folkmq/server/MqQueueDefault.java
@@ -192,7 +192,7 @@ protected void distribute0(MqMessageHolder messageHolder) {
             return;
         }
 
-        if(messageHolder.getExpiration() > 0 && messageHolder.getExpiration() > System.currentTimeMillis()){
+        if(messageHolder.getExpiration() > 0 && messageHolder.getExpiration() < System.currentTimeMillis()){
             //已过期
             messageMap.remove(messageHolder.getTid());
             return;