suntianji123 opened a new issue #2620:
URL: https://github.com/apache/rocketmq/issues/2620
/**
* 正确的到期时间
* @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;
}
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
