延迟发送逻辑
- 根据延迟时间和当前时间差值计算延迟等级
Integer level = DelayLevelCalculate.calculateDefault(l);
- 标记该消息为延迟消息 希望该消息被消费的时候 若发现是延迟消息即还未到消费的时间 则不消费 再次的触发生产者生产一次该消息
fillMessage(msg, level, startSendTime);
Integer level = DelayLevelCalculate.calculateDefault(l);
fillMessage(msg, level, startSendTime);