当前位置:首页 > 编程笔记 > 正文
已解决

RabbitMQ(高级特性) 设置队列所有消息存活时间

来自网友在路上 198898提问 提问时间:2023-11-07 22:09:24阅读次数: 98

最佳答案 问答题库988位专家为你答疑解惑

RabbitMQ可以设置消息的存活时间(Time To Live,简称TTL),当消息到达存活时间后还没有被消费,会被移出队列。RabbitMQ可以对队列的所有消息设置存活时间,也可以对某条消息设置存活时间。

@Configuration
public class RabbitConfig2 {private final String EXCHANGE_NAME="my_topic_exchange2";private final String QUEUE_NAME="my_queue2";// 1.创建交换机@Bean("bootExchange2")public Exchange getExchange2(){return ExchangeBuilder.topicExchange(EXCHANGE_NAME).durable(true).build();}// 2.创建队列@Bean("bootQueue2")public Queue getMessageQueue2(){return QueueBuilder.durable(QUEUE_NAME).ttl(10000) //队列的每条消息存活10s.build();}// 3.将队列绑定到交换机@Beanpublic Binding bindMessageQueue2(@Qualifier("bootExchange2") Exchange exchange, @Qualifier("bootQueue2") Queue queue){return BindingBuilder.bind(queue).to(exchange).with("my_routing").noargs();}
}
查看全文

99%的人还看了

猜你感兴趣

版权申明

本文"RabbitMQ(高级特性) 设置队列所有消息存活时间":http://eshow365.cn/6-34788-0.html 内容来自互联网,请自行判断内容的正确性。如有侵权请联系我们,立即删除!