6 years ago
parent
commit
e64faff6a6
  1. 2
      tall/src/main/java/com/ccsens/tall/service/MessageService.java
  2. 3
      tall/src/main/java/com/ccsens/tall/service/TaskSubTimeService.java

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

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

Loading…
Cancel
Save