消息优化

cloud-web-manage/src/main/java/com/yizhi/application/util/TaskSendMessage.java

 package com.yizhi.application.util;
 package com.yizhi.application.util;
 
 
-import com.yizhi.assignment.application.vo.MessageRemindVo;
+import com.yizhi.core.application.publish.PublicSendMessageClient;
+import com.yizhi.core.application.vo.MessageRemindVo;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.event.EventWrapper;
 import com.yizhi.core.application.event.EventWrapper;
 import com.yizhi.core.application.publish.CloudEventPublisher;
 import com.yizhi.core.application.publish.CloudEventPublisher;
@@ -16,7 +17,7 @@ import org.springframework.stereotype.Component;
 public class TaskSendMessage {
 public class TaskSendMessage {
 
 
     @Autowired
     @Autowired
-    private CloudEventPublisher cloudEventPublisher;
+    private PublicSendMessageClient publicSendMessageClient;
     @Autowired
     @Autowired
     private TaskExecutor taskExecutor;
     private TaskExecutor taskExecutor;
     private Logger logger = LoggerFactory.getLogger(TaskSendMessage.class);
     private Logger logger = LoggerFactory.getLogger(TaskSendMessage.class);
@@ -46,7 +47,7 @@ public class TaskSendMessage {
             taskExecutor.asynExecute(new AbstractTaskHandler() {
             taskExecutor.asynExecute(new AbstractTaskHandler() {
                 @Override
                 @Override
                 public void handle() {
                 public void handle() {
-                    cloudEventPublisher.publish(Constans.MESSAGE_QUEUE, new EventWrapper<MessageRemindVo>(null, vo));
+                    publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
                 }
                 }
             });
             });
             if (taskStatus == 1) {
             if (taskStatus == 1) {