message.getMessageProperties().setDelay(ttl); 这种方式设置延迟时间话,理论上最多24天左右。因为.setDelay 的参数是Integer类型的,25天的时候就超过了Integer的长度了,变成了负数,下游立马收到消息的。建议改为 message.getMessageProperties().getHeaders().put("x-delay",delay);
RabbitMQ实现延迟消息(rabbitmq_delayed_message_exchange)下载延迟消息插件 Warning:请检查你的RabbitMQ版本与插件兼容是否一致 官方下载地址[https://www.rabbitmq.com/community-plu...