Springboot ActiveMQ 消息重发延迟时间 坑记
正确配置:
@Beanpublic RedeliveryPolicy redeliveryPolicy(){RedeliveryPolicy redeliveryPolicy= new RedeliveryPolicy();//是否在每次尝试重新发送失败后,增长这个等待时间redeliveryPolicy.setUseExponentialBackOff(true);//重发次数,默认为6次 redeliveryPolicy.setMaximumRedeliveries(3);//重发时间间隔,默认为1秒 !!!! redeliveryPolicy.setInitialRedeliveryDelay(2000);//第一次失败后重新发送之前等待2000毫秒,第二次失败再等待2000 * 2毫秒,这里的2就是valueredeliveryPolicy.setBackOffMultiplier(2);//是否避免消息碰撞redeliveryPolicy.setUseCollisionAvoidance(false);//设置重发最大拖延时间-1 表示没有拖延只有UseExponentialBackOff(true)为true时生效redeliveryPolicy.setMaximumRedeliveryDelay(-1);return redeliveryPolicy;}
坑点,这个延迟时间属性设置时毫秒级别,别再 人传人 设置一个 个位数 了:
![](/assets/blank.gif)
消费失败时,自动延迟重发,可以看到延迟秒数生效:
Springboot ActiveMQ 消息重发延迟时间 坑记相关推荐
- ActiveMQ消息重发
2019独角兽企业重金招聘Python工程师标准>>> 消息重发的问题: 1. 处理失败 指的是MessageListener的onMessage方法里抛出RuntimeExcept ...
- activeMQ - 消息重发策略和DLQ死信队列
2019独角兽企业重金招聘Python工程师标准>>> 1:死信队列简介 DLQ-死信队列(Dead Letter Queue)用来保存处理失败或者过期的消息. 出现以下情况时,消息 ...
- activemq和mysql_activeMQ 填坑记
前言 MQ是现在大型系统架构中必不可少的一个重要中间件,之前有偏文章<MQ(消息队列)常见的应用场景解析>介绍过MQ的应用场景,现在流行的几个MQ是rabbitmq,rocketma,ka ...
- SpringBoot + Spark on Yan踩坑记
终极目标 采用SpringBoot集成SparkStreaming+Kafka+Redis+HDFS等组件,打包成jar(下文将之简称为"应用"),运行在Spark on Yan环 ...
- SpringBoot集成ActiveMq消息队列实现即时和延迟处理
原文链接:https://blog.csdn.net/My_harbor/article/details/81328727 一.安装ActiveMq 具体安装步骤:自己谷歌去 二.新建springbo ...
- SpringBoot整合activeMQ消息队列手动签收(Session.CLIENT_ACKNOWLEDGE)为什么失效啊?
今天在家隔离办公,不太忙,然后就琢磨起来消息队列activeMQ的消息事务来解决分布式事务,但是奈何在SpringBoot整合activeMQ时,其消费者手动签收消息时出现了问题-->当acti ...
- ActiveMQ的消息重发策略和DLQ处理
2019独角兽企业重金招聘Python工程师标准>>> ActiveMQ的消息重发策略和DLQ处理 博客分类: MQ 在以下三种情况中,ActiveMQ消息会被重发给客户端/消费者: ...
- ActiveMQ的消息重发机制
本文以ActiveMQ最新的5.10版本为准. 大家知道,JMS规范中,Message消息头接口中有setJMSRedelivered(boolean redelivered)和getJMSRedel ...
- activemq消息丢失_Kafka or RabbitMQ:消息中间件选型深入分析
消息中间件选型深入分析 --从Kafka与RabbitMQ的对比来看全局 有很多网友留言:公司要做消息中间件选型,该如何选?你觉得哪个比较好?消息选型的确是一个大论题,实则说来话长的事情又如何长话短说 ...
最新文章
- java Proxy(代理机制)
- 机器人抓取方式,值得研究。
- bootstrap-表单控件——单选按钮水平排列
- netbeans调试_从NetBeans运行和调试WildFly Swarm应用程序
- MyEclipse + Tomcat + Eclipse 开发调试WEB应用
- PHP程序员面临的成长瓶颈
- re正则表达式7_{}
- 棋牌搭建,APP新手教程
- 计算机应届博士生的一点求职经验——概述篇
- 浪潮服务器bios设置 改硬盘接口,bios设置中更改硬盘接口模式为ide的方法
- Echarts中国地图json文件,去除诸岛
- 由于计算机启动了配置文件,提示由于启动计算机时出现了页面文件配置问题解决方法...
- iOS——weak实现原理
- message——UVM
- Python-分类问题示例-OneR-学习笔记
- (39.1)【XML漏洞专题】必备的基础知识、利用原理、构建规则
- 电脑双屏断开后文件无法显示
- Linux上重置MySQL密码 错误 ERROR 1045 (28000): Access denied for user ‘‘root‘‘@‘‘localhost‘‘ (using passw...
- 《程序员的数学》第二册 (概率统计)
- 阿里云Mysql5.7 数据库恢复 qp.xb文件恢复数据