我们可以使用管控台来设置消息的最大生存时间,当然了也可以设置一系列的参数信息,然后再创建好影响的exchange,queue,以及绑定好关系之后,发送一条消息;
等待一定时间,如果这个消息没有被消费掉就会自动的删除掉了。
而在代码中是可以在properties中设置的:
AMQP.BasicProperties properties = new AMQP.BasicProperties().builder()
.deliveryMode(2)
.contentEncoding("UTF-8")
.expiration("10000")
.build();
其中expiration属性就是设置过期时间的。
网友评论