gpt4 book ai didi

RabbitMQ - 如何覆盖 sendAndReceive 的回复超时?

转载 作者:行者123 更新时间:2023-12-02 18:54:54 25 4
gpt4 key购买 nike

我正在使用 spring amqp 定义配置 amqp 模板,如

<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" reply-timeout="45000" />

现在,在调用amqpTemplate.sendAndReceive("COR.QUEUE", message)时,我可以更改特定请求的replyTimeout吗?

最佳答案

您无法更改单个发送操作的超时;它是一个常数值。

如果您只需要几个不同的值,则可以简单地声明多个模板,每个模板都有不同的超时。

您还可以创建一个包装类,该类按需创建多个模板,每个模板对应一个请求的超时。

private final Map<Long, RabbitTemplate> templates = new HashMap<>();

public Message sendAndReceive(String rk, Message message, long timeout) {
// lookup a template for the requested timeout, or add one to the map
return lookedupTemplate.sendAndReceive(rk, message);
}

关于RabbitMQ - 如何覆盖 sendAndReceive 的回复超时?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46093735/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com