springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActAcidRecordServiceImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActAcidRecordServiceImpl.java
@@ -162,7 +162,7 @@ ComActAcidDangerMemberVO dangerMemberVO = new ComActAcidDangerMemberVO(); BeanUtils.copyProperties(dangerMember, dangerMemberVO); rabbitTemplate.convertAndSend("huacheng.acid.danger.exchange", "huacheng.acid.danger.key", dangerMemberVO, message -> { message.getMessageProperties().setHeader("x-delay", 5*60*1000); message.getMessageProperties().setHeader("x-delay", 1*60*1000); return message; }); }