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