f1amingo opened a new pull request, #1314: URL: https://github.com/apache/rocketmq-clients/pull/1314
### Summary Introduce `LiteSimpleConsumer` for consuming lite topic messages in pull mode, and extract the lite subscription logic shared with `LitePushConsumer` into a reusable `liteSubscriptionManager`. ### Changes - Add `LiteSimpleConsumer` interface and implementation with `SubscribeLite` / `UnSubscribeLite` / `GetLiteTopicSet` - Extract `liteSubscriptionManager` (subscribe/unsubscribe, periodic full sync every 30s, server-side unsubscribe notification) shared by lite push/simple consumers - Carry `LiteTopic` in Ack and ChangeInvisibleDuration requests for lite simple consumer - Filter topic route to a single readable master queue for lite simple consumer - Report actual client type in heartbeat instead of hardcoded `SIMPLE_CONSUMER` ### How Did You Test This Change? - Unit tests: `lite_simple_consumer_test.go`, `lite_subscription_manager_test.go` (all pass) - Manual end-to-end verification of lite topic message send/receive/ack -- 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]
