K8s

RabbitMQ高级特性-5.TTL队列、消息

2021-12-24  本文已影响0人  那钱有着落吗

我们可以使用管控台来设置消息的最大生存时间,当然了也可以设置一系列的参数信息,然后再创建好影响的exchange,queue,以及绑定好关系之后,发送一条消息;

等待一定时间,如果这个消息没有被消费掉就会自动的删除掉了。

而在代码中是可以在properties中设置的:

AMQP.BasicProperties properties = new AMQP.BasicProperties().builder()
                .deliveryMode(2)
                .contentEncoding("UTF-8")
                .expiration("10000")
                .build();

其中expiration属性就是设置过期时间的。

上一篇下一篇

猜你喜欢

热点阅读