当前位置:   article > 正文

Java笔记-spring-rabbitmq中queue设置argument(添加x-message-ttl)_java @queuebinding @argument

java @queuebinding @argument

最近在读Spring的官方文档,在此记录下自己做的小实验。

这里主要是在生产者中声明和添加:

  1. @Bean
  2. Queue queue(){
  3. Queue queue = new Queue(queueName, false);
  4. queue.addArgument("x-message-ttl" , 30 * 1000);
  5. return queue;
  6. }
  7. @Bean
  8. TopicExchange exchange(){
  9. return new TopicExchange(topicExchangeName);
  10. }
  11. @Bean
  12. Binding binding(Queue queue, TopicExchange exchange){
  13. return BindingBuilder.bind(queue).to(exchange).with("Hello.*");
  14. }

使用Rabbitmq管理工具可以看到起有个TTL的小特征

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/126936
推荐阅读
相关标签
  

闽ICP备14008679号