Queue 13 DelayLV 14:10m
NM.Topic = PROPERTY_REAL_TOPIC
ScheduleMessageService
Queue 11 DelayLV 12:8m
Task
clearPropertyPROPERTY_DELAY_TIME_LEVEL
Queue 3 DelayLV 4:30s
Queue 10 DelayLV 11:7m
Queue 0 DelayLV 1:1s
CommitLog
Queue 4 DelayLV 5:1m
TimeUp
Queue 9 DelayLV 10:6m
Overview
Queue 1 DelayLV 2:5s
Start
Queue 17 DelayLV 18:2h
Re-Deliver
Timeup
lookMessageByOffset
Queue 8 DelayLV 9:5m
Queue 5 DelayLV 6:2m
Dispatch NM into ConsumeQueueNM.Tag = DeliverTime
NM = lookMessageByOffset
Schedule Delay Messages
Queue 12 DelayLV 13:9m
Queue 14 DelayLV 15:20m
Persistence
Queue 2 DelayLV 3:10s
MessageStore.putMessage
Queue 16 DelayLV 17:1h
Queue 15 DelayLV 16:30m
QueueId = DelayLV - 1
Append NM into CommitLog
Queue 7 DelayLV 8:4m
Detail
Consume Queue
Queue 6 DelayLV 7:3m
Topic: SCHEDULE_TOPIC_XXXX
DeliverDelayedMessageTimerTask
Dispatch
