RockteMQ-AI commented on issue #780: URL: https://github.com/apache/rocketmq-spring/issues/780#issuecomment-5529963158
**Issue Evaluation** Category: `type/bug` | Status: **Confirmed** The reported issue has been verified. `RocketMQClientTemplate.receiveAsync()` incorrectly closes the shared `SimpleConsumer` singleton after initiating an async receive, which: 1. Disrupts the in-flight async operation 2. Permanently breaks the template for all subsequent operations The synchronous `receive()` method does not exhibit this behavior, confirming this is a lifecycle management bug. **Root Cause:** Premature `simpleConsumer.close()` call in the async path **Impact:** All consumer operations fail after first `receiveAsync()` call **Severity:** High - breaks core functionality A fix is straightforward: remove the `close()` call and let the Spring bean lifecycle manage it via `destroy()`. --- *Automated evaluation by RockteMQ-AI* -- 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]
