mq配置遗漏文件

epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/send/SendMqMsgUtil.java

@@ -243,4 +243,28 @@ public class SendMqMsgUtil {
         return false;
     }
 
+    /**
+     * @Description 党建小助手消息同步Mq
+     * @author sun
+     */
+    public boolean partyMeetingMQMsg(String msgType, PartyMeetingMessageMQMsg msgContent) {
+        try {
+            SystemMsgFormDTO form = new SystemMsgFormDTO(msgType,msgContent);
+            Result sendMsgResult;
+            log.info("partyMeetingMQMsg param:{}",msgContent);
+            int retryTime = 0;
+            do {
+                sendMsgResult = epmetMessageOpenFeignClient.sendSystemMsgByMQ(form);
+            } while ((sendMsgResult == null || !sendMsgResult.success()) && retryTime++ < NumConstant.TWO);
+
+            if (sendMsgResult != null && sendMsgResult.success()) {
+                return true;
+            }
+            log.error("发送党建小助手系统消息到message服务失败:{},msg:{}", JSON.toJSONString(sendMsgResult), JSON.toJSONString(form));
+        } catch (Exception e) {
+            log.error("partyMeetingMQMsg exception", e);
+        }
+        return false;
+    }
+
 }