BurningCN commented on issue #4451: URL: https://github.com/apache/rocketmq/issues/4451#issuecomment-1158439979
在`rebalance`的时候，`this.lock(mq)`执行之后，`mq`在`broker`是锁定的，但是`processQueue.isLocked`还是`false`，然后接着执行`this.processQueueTable.putIfAbsent(mq,pq);`此时table才有了此entry。 这样定时任务`ConsumeMessageOrderlyService#lockMQPeriodically`再次执行lock的时候才能拿到processQueue（前面的entry）并置为locked。而`lockMQPeriodically`第一次执行是在1s后 -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
