f1amingo opened a new pull request, #11164:
URL: https://github.com/apache/rocketmq/pull/11164

   ### Which Issue(s) This PR Fixes
   
   - Fixes #11163
   
   ### Brief Description
   
   The lite topic prefix index is maintained only when the dispatcher sees 
offset == 0, but the message-arriving notification carries logicOffset = 
queueOffset + 1, so the first message of a lite topic arrives with offset == 1. 
The create hook thus never fires at runtime, and lite topics created after 
startup are missing from wildcard dispatch and parent-topic collect/count/clean 
until the broker restarts. This PR corrects the comparison to offset == 1 and 
restores the store-dependent lifecycle tests to the concrete impl test classes 
(file CQ and RocksDB CQ), driving the index through the real putMessage -> 
notify -> dispatch path so this behavior is covered.
   
   ### How Did You Test This Change?
   
   Unit tests in LiteLifecycleManagerTest (file CQ) and 
RocksDBLiteLifecycleManagerTest (RocksDB CQ) wire a real 
MessageArrivingListener + LiteEventDispatcher and assert collectByParentTopic / 
getLiteTopicCount / cleanByParentTopic against real putMessage. Before the fix 
they fail with an empty index; after the fix the lite test package passes (19 
run, 0 failures). Checkstyle clean.
   


-- 
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]

Reply via email to