流程疑问

org.example.service.AgentService.class#processRequestAndEmitStream

在这种方法中，如果streamCallWithMessage智能体没有在15秒内流结束。返回 监听的消息消费 失败。
线程池设置60秒，异步获取结果15分钟，设置多少都不合适，如果时间过长，会卡住mq消费线程。
所以这里 感觉 不适合 用 mq 做 请求的异步消息。

Start by reading org.example.service.AgentService.class#processRequestAndEmitStream and tracing the 15-second stream timeout, thread-pool limit, asynchronous result wait, and MQ consumer behavior. Confirm the intended timeout and message-handling semantics; done requires an agreed design or a clearly specified change, with tests or reproduction steps added for the failure case.

Written by the indexing model from the issue text.