@@ -182,7 +182,7 @@ public class ESConsumer implements RocketMQListener<ESJobAdvertisedMergeSendMess
**/
private boolean checkJobExpireTime(JobAdvertisedDO job) {
if(null == job.getExpireTime()) {
- return true;
+ return false;
}
return job.getExpireTime().isBefore(LocalDateTime.now());