消息队列AMQP Spring Boot发送延时消息-阿里云开发者社区

开发者社区> 微服务> 正文

消息队列AMQP Spring Boot发送延时消息

简介: 消息队列AMQP Spring Boot发送延时消息

延时消息官方文档只给了纯 Java 的实现代码。

而官方提供的Spring Boot demo中没有涉及到延时消息。

可以直接修改下Sender

代码修改如下:

public void send() {
        String exchange = "exchangeName";
        String routingKey = "product";
        String message = LocalDateTime.now().toString() + "延时消息";
        System.out.println(LocalDateTime.now().toString());
        rabbitTemplate.convertAndSend(exchange, routingKey, message, new MessagePostProcessor() {
            public Message postProcessMessage(Message message) throws AmqpException {
                message.getMessageProperties().setHeader("delay",6000);//延迟6秒
                return message;
            }
        });


    }

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
微服务
使用钉钉扫一扫加入圈子
+ 订阅

构建可靠、高效、易扩展的技术基石

其他文章