imjyz opened a new pull request, #1333: URL: https://github.com/apache/rocketmq-clients/pull/1333
### Which Issue(s) This PR Fixes Related to apache/rocketmq-clients#1315 ### Brief Description Add synchronous and asynchronous `SimpleConsumer.receive` overloads that accept a topic selected from the current subscriptions. The existing receive APIs remain unchanged and continue to select across all subscribed topics. The new overloads reuse the subscribed filter expression and fail with `IllegalArgumentException` when the requested topic is not currently subscribed. This PR implements topic-aware receive only. Queue-aware receive and exposing topic route data remain outside this change. ### How Did You Test This Change? - Added tests for receiving from a specified subscribed topic. - Added tests for unsubscribed topics, topics removed by `unsubscribe`, and consumers that are not running. - Ran `SimpleConsumerImplTest`: 11 tests passed with no failures. - Verified the Java API/client modules compile and pass Checkstyle and SpotBugs. -- 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]
