码迷,mamicode.com
首页 > 其他好文 > 详细

rabbitmq使用延迟时报异常

时间:2019-08-02 16:33:46      阅读:227      评论:0      收藏:0      [点我收藏+]

标签:rri   sage   bsp   service   安装位置   bit   ble   pex   png   

声明交换机为延迟时报异常( unknown exchange type ‘x-delayed-message‘)的解决方法

服务端需下载安装插件:

1.下载插件包

技术图片

2.将下载后的插件包移至服务安装目录下

rpm -ql rabbitmq-server查询安装位置
将下载的ez结尾的文件移至/plugins/目录下

3.启动插件

        [root@localhost plugins]# rabbitmq-plugins enable rabbitmq_delayed_message_exchange
        [root@localhost plugins]# systemctl restart rabbitmq-server.service

4.消息发送时添加head

        rabbitTemplate.convertAndSend("test_publish_exchange",routingKey,content,new MessagePostProcessor() {
                    @Override
                    public Message postProcessMessage(Message message) throws AmqpException {
                        //设置消息持久化
                        //message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);
                        //message.getMessageProperties().setHeader("x-delay", "6000");
                        message.getMessageProperties().setDelay(6000);
                        return message;
                    }
                });

 

rabbitmq使用延迟时报异常

标签:rri   sage   bsp   service   安装位置   bit   ble   pex   png   

原文地址:https://www.cnblogs.com/lantuanqing/p/11289107.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!