发布post之后发送消息

src/main/java/cn/meteor/beyondclouds/modules/post/service/impl/PostServiceImpl.java

 package cn.meteor.beyondclouds.modules.post.service.impl;
 
+import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
+import cn.meteor.beyondclouds.core.queue.message.DataItemType;
 import cn.meteor.beyondclouds.modules.post.entity.Post;
 import cn.meteor.beyondclouds.modules.post.entity.PostComment;
 import cn.meteor.beyondclouds.modules.post.enums.PostErrorCode;
@@ -7,6 +9,7 @@ import cn.meteor.beyondclouds.modules.post.exception.PostServiceException;
 import cn.meteor.beyondclouds.modules.post.mapper.PostMapper;
 import cn.meteor.beyondclouds.modules.post.service.IPostService;
 import cn.meteor.beyondclouds.modules.project.exception.ProjectServiceException;
+import cn.meteor.beyondclouds.modules.queue.service.IMessageQueueService;
 import cn.meteor.beyondclouds.modules.user.entity.User;
 import cn.meteor.beyondclouds.modules.user.service.IUserService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -31,11 +34,18 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
 
     private IUserService userService;
 
+    private IMessageQueueService messageQueueService;
+
     @Autowired
     public void setUserService(IUserService userService) {
         this.userService = userService;
     }
 
+    @Autowired
+    public void setMessageQueueService(IMessageQueueService messageQueueService) {
+        this.messageQueueService = messageQueueService;
+    }
+
     /**
      * 发布动态
      * @param post
@@ -71,6 +81,7 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
         //2.保存动态
         save(post);
 
+        messageQueueService.sendItemUpdateMessage(DataItemChangeMessage.addMessage(DataItemType.POST, post.getPostId()));
 
     }
 
@@ -93,6 +104,9 @@ public class PostServiceImpl extends ServiceImpl<PostMapper, Post> implements IP
 
         //2.删除动态
         removeById(postId);
+
+        messageQueueService.sendItemUpdateMessage(DataItemChangeMessage.deleteMessage(DataItemType.POST, post.getPostId()));
+
     }
 
 

src/main/java/cn/meteor/beyondclouds/modules/question/service/impl/QuestionServiceImpl.java

 package cn.meteor.beyondclouds.modules.question.service.impl;
 
 import cn.meteor.beyondclouds.core.authentication.Subject;
+import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
+import cn.meteor.beyondclouds.core.queue.message.DataItemType;
 import cn.meteor.beyondclouds.modules.question.dto.QuestionDetailDTO;
 import cn.meteor.beyondclouds.modules.question.entity.*;
 import cn.meteor.beyondclouds.modules.question.enums.QuestionErrorCode;
@@ -10,9 +12,7 @@ import cn.meteor.beyondclouds.modules.question.exception.QuestionTagServiceExcep
 import cn.meteor.beyondclouds.modules.question.mapper.QuestionMapper;
 import cn.meteor.beyondclouds.modules.question.service.*;
 import cn.meteor.beyondclouds.modules.question.util.QuestionUtils;
-import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
 import cn.meteor.beyondclouds.modules.queue.service.IMessageQueueService;
-import cn.meteor.beyondclouds.core.queue.message.DataItemType;
 import cn.meteor.beyondclouds.modules.tag.entity.Tag;
 import cn.meteor.beyondclouds.modules.tag.service.ITagService;
 import cn.meteor.beyondclouds.modules.topic.entity.Topic;