about delay queue has expired but there are no consumers

[zhang141650]

version：3.20.0

以下是消费者代码

    @PostConstruct
    public void init() {
        for (DelayQueueEnum queueEnum : DelayQueueEnum.values()) {
            MQConsumer delayQueueConsumer = SpringUtil.getBean(queueEnum.getClazz());
            if (delayQueueConsumer == null) {
                throw new ServiceException("queueName=" + queueEnum.getClazz() + ",delayQueueConsumer=null,请检查配置...");
            }
            ThreadUtil.execAsync(() -> {
                while (true) {
                    try {
                        String queueName = queueEnum.getQueName();
                        MQContextDTO contextDTO = QueueUtils.getDelayedQueueObjectTake(queueName);
                        if (ObjUtil.isNull(contextDTO) || StrUtil.equals(contextDTO.getMessageType(), "0")) {
                            continue;
                        }
                        delayQueueConsumer.listener(contextDTO);
                    } catch (Exception e) {
                        log.error(e.getMessage());
                    }
                }
            }, true);
        }
    }

现象：延时队列消息过期之后，没有监听到消息过期，直到下次发送消息的时候才能监听到过期消息