From 112f7db270ba406d01e804a016d5b88cc5accd9a Mon Sep 17 00:00:00 2001 From: ma <1062634917@qq.com> Date: Thu, 21 Oct 2021 09:40:33 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=B8=80=E9=94=AE=E9=80=9A?= =?UTF-8?q?=E7=9F=A5=E6=B6=88=E6=81=AF=E5=8F=91=E9=80=81=E8=A7=84=E5=88=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/ccsens/carbasics/mq/QcpButtonReceive.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/main/java/com/ccsens/carbasics/mq/QcpButtonReceive.java b/src/main/java/com/ccsens/carbasics/mq/QcpButtonReceive.java index 3f0666d..068d0af 100644 --- a/src/main/java/com/ccsens/carbasics/mq/QcpButtonReceive.java +++ b/src/main/java/com/ccsens/carbasics/mq/QcpButtonReceive.java @@ -201,6 +201,10 @@ public class QcpButtonReceive { inMessage.setTos(userSet); inMessage.setData(JacksonUtil.beanToJson(buttonStartVo)); inMessage.setToDomain(MessageConstant.DomainType.User); + MessageRule messageRule = MessageRule.defaultRule(MessageConstant.DomainType.Queue); + messageRule.setAckRule(MessageRule.AckRule.ALWAYS); + messageRule.setOfflineDiscard((byte) 1); + inMessage.setRule(messageRule); log.info("一键启动调用消息系统传参{}",inMessage); amqpTemplate.convertAndSend(RabbitMQConfig.MESSAGE_QUEUE_NAME,JacksonUtil.beanToJson(inMessage)); } @@ -257,6 +261,10 @@ public class QcpButtonReceive { inMessage.setTos(userSet); inMessage.setData(JacksonUtil.beanToJson(updateStatusVo)); inMessage.setToDomain(MessageConstant.DomainType.User); + MessageRule messageRule = MessageRule.defaultRule(MessageConstant.DomainType.Queue); + messageRule.setAckRule(MessageRule.AckRule.ALWAYS); + messageRule.setOfflineDiscard((byte) 1); + inMessage.setRule(messageRule); log.info("更改状态调用消息系统传参{}",inMessage); amqpTemplate.convertAndSend(RabbitMQConfig.MESSAGE_QUEUE_NAME,JacksonUtil.beanToJson(inMessage)); }