From 11399e1e8f4ed14814a46c256ca8703e0894b2b8 Mon Sep 17 00:00:00 2001
From: zhangye <654600784@qq.com>
Date: Sat, 28 Dec 2019 15:58:07 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=AE=A1=E6=97=B6=E5=99=A8id?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tall/src/main/java/com/ccsens/tall/service/MessageService.java | 2 +-
 .../main/java/com/ccsens/tall/service/TaskSubTimeService.java  | 3 +++
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/tall/src/main/java/com/ccsens/tall/service/MessageService.java b/tall/src/main/java/com/ccsens/tall/service/MessageService.java
index c2dc10f2..adfb5912 100644
--- a/tall/src/main/java/com/ccsens/tall/service/MessageService.java
+++ b/tall/src/main/java/com/ccsens/tall/service/MessageService.java
@@ -93,7 +93,7 @@ public class MessageService implements IMessageService{
     public void sendStartTaskMessage(SyncMessageWithStartDto syncMessage) throws Exception {
         System.out.println(JacksonUtil.beanToJson(syncMessage));
         //FixMe 发送到消息队列
-        rabbitTemplate.convertAndSend(RabbitMQConfig.TALL_MESSAGE_1 ,
+        rabbitTemplate.convertAndSend(RabbitMQConfig.RabbitMQ_QUEUE_NAME ,
                 JacksonUtil.beanToJson(syncMessage));
     }
 }
diff --git a/tall/src/main/java/com/ccsens/tall/service/TaskSubTimeService.java b/tall/src/main/java/com/ccsens/tall/service/TaskSubTimeService.java
index 022790a9..b4cc9a76 100644
--- a/tall/src/main/java/com/ccsens/tall/service/TaskSubTimeService.java
+++ b/tall/src/main/java/com/ccsens/tall/service/TaskSubTimeService.java
@@ -229,6 +229,9 @@ public class TaskSubTimeService implements ITaskSubTimeService {
             BaseMessageDto.MessageUser messageUser1996 = new BaseMessageDto.MessageUser();
             messageUser1996.setUserId(1996L);
             messageUserList.add(messageUser1996);
+            BaseMessageDto.MessageUser messageUser1998 = new BaseMessageDto.MessageUser();
+            messageUser1998.setUserId(1998L);
+            messageUserList.add(messageUser1998);
 
             syncMessage.setData(syncMessageData);
             syncMessage.setReceivers(messageUserList);