添加一键通知消息发送规则

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));
                     }