插件的安装,本文就不做描述了,插件安装后如下,就说明安装成功了
1 添加pom依赖,yml配置就不讲了
2 核心类,定义交换机的代码改成如下,其它的定义队列,设置绑定关系,设置死信等,都是一样的,唯一就是Binding那里,最后添加.noargs(),idea也会自动识别处理的,就不粘代码了
@Bean
public CustomExchange delayed_Exchang_1()
{
Map<String, Object> map = new HashMap<>();
//自定义交换机的类型,后面的参数自己调整,topic,direct等
map.put("x-delayed-type","topic");
CustomExchange customExchange = new CustomExchange("delayed_Exchang_1", "x-delayed-message", true, false,map);
return customExchange;
}
3 生产者核心代码
MessageProperties messageProperties = new MessageProperties();
//延迟5秒
messageProperties.setDelay(5000);
Message message = new Message("消息", messageProperties);
rabbitTemplate.convertAndSend("delayed_Exchang_1",
"china.chongqing.aa",
message);