RockteMQ-AI commented on issue #11323: URL: https://github.com/apache/rocketmq/issues/11323#issuecomment-6110379491
**Issue Evaluation** Category: `type/bug` (example) | Status: **Confirmed** The request-reply `ResponseConsumer` example calls `consumer.sendMessageBack(msg, ConsumeConcurrentlyStatus.CONSUME_SUCCESS)` even when the reply send fails. This acks the original request as consumed, so the broker will not redeliver it — the request is silently lost. **Suggested fix:** Only ack with `CONSUME_SUCCESS` when the reply send succeeds; use `RECONSUME_LATER` or throw an exception when it fails, so the broker can redeliver. --- *Automated evaluation by RocketMQ-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]
