关于Rocketmq4.5.2 ScheduleMessageService的一个问题

/** * 正确的到期时间 * @param now 当前时间 * @param deliverTimestamp 延时消息的截止时间 * @return */ private long correctDeliverTimestamp(final long now, final long deliverTimestamp) { //延时消息的截止时间 long result = deliverTimestamp;

    long maxTimestamp = now + ScheduleMessageService.this.delayLevelTable.get(this.delayLevel);
    if (deliverTimestamp > maxTimestamp) {//这里应该改为maxTimestamp > deliverTimestamp
        result = now;
    }

    return result;
}

原提问者GitHub用户suntianji123