我有一个使用 spring 集成和 amqp 实现的请求/回复。请求可能需要很长时间才能处理(在某些情况下甚至可能需要一个小时),由于某种原因客户端抛出异常 -
Exception in thread "main" org.springframework.integration.handler.ReplyRequiredException: No reply produced by handler 'client', and its 'requiresReply' property is set to true.
我的客户端配置如下。
<int-amqp:outbound-gateway
id="client"
request-channel="in"
reply-channel="res"
exchange-name="reportingServer"
routing-key-expression="'report.req.'+headers.id"
amqp-template="amqpTemplate" requires-reply="true">
</int-amqp:outbound-gateway>
我相信回复超时默认值为-1,表示无限期等待,但不确定为什么它不起作用,任何帮助将不胜感激。
在 amqp 中实施如此长时间的等待操作是否还有任何已知问题,或者应该没问题?
谢谢你