Aias00 opened a new pull request, #10767: URL: https://github.com/apache/rocketmq/pull/10767
### Which Issue(s) This PR Fixes Fixes #10766 ### Brief Description When a gRPC telemetry command cannot be dispatched for relay-style requests, the registered response future used to stay in `GrpcChannelManager` until the timeout cleanup path handled it. This PR makes the write path report dispatch failure and completes/removes the pending future immediately for: - `GetConsumerRunningInfo` - `ConsumeMessageDirectly` The observer-null and observer-write-failure paths now return a structured `SYSTEM_BUSY` relay result instead of leaving callers pending. ### How Did You Test This Change? - `mvn -q -pl proxy -Dtest=GrpcClientChannelTest test` The test run passes with 3 tests. The local output still contains existing JaCoCo Java 17 instrumentation warnings, but Maven exits successfully. -- 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]
