update

components/data/MongodbData/src/main/java/com/github/microservice/components/data/mongo/queue/dao/impl/ExecQueueDaoImpl.java

@@ -37,7 +37,7 @@ public class ExecQueueDaoImpl implements ExecQueueDaoExtend {
                 Criteria.where("status").is(ExecQueue.ExecQueueStatus.Wait)
                         .and("nextTime").lt(this.dbHelper.getTime())
                         // 尝试次数未超过最大次数
-                        .and("$expr").lt(new String[]{"$currentTryCount", "$maxTryCount"})
+                        .and("$expr").lte(new String[]{"$currentTryCount", "$maxTryCount"})
         );
         query.with(Sort.by(Sort.Direction.ASC, "nextTime", "workTime"));