正在显示
1 个修改的文件
包含
3 行增加
和
7 行删除
@@ -34,9 +34,6 @@ import static com.sunyo.wlpt.message.bus.service.common.Constant.RESULT_SUCCESS; | @@ -34,9 +34,6 @@ import static com.sunyo.wlpt.message.bus.service.common.Constant.RESULT_SUCCESS; | ||
34 | public class RabbitController { | 34 | public class RabbitController { |
35 | 35 | ||
36 | @Resource | 36 | @Resource |
37 | - private MessageNoteService messageNoteService; | ||
38 | - | ||
39 | - @Resource | ||
40 | private UserMessageBindingService userMessageBindingService; | 37 | private UserMessageBindingService userMessageBindingService; |
41 | 38 | ||
42 | @Resource | 39 | @Resource |
@@ -121,11 +118,10 @@ public class RabbitController { | @@ -121,11 +118,10 @@ public class RabbitController { | ||
121 | // 4、mq发送消息,数据库中保存消息 | 118 | // 4、mq发送消息,数据库中保存消息 |
122 | ResultJson result = directUtils.sendMessage(sentData); | 119 | ResultJson result = directUtils.sendMessage(sentData); |
123 | 120 | ||
124 | - messageNoteService.insertMessageSelective(sentData); | ||
125 | // 异步,保存消息记录 | 121 | // 异步,保存消息记录 |
126 | -// CountDownLatch latch = new CountDownLatch(1); | ||
127 | -// Future<String> future = asyncTaskService.saveMessage(sentData, latch); | ||
128 | -// latch.await(); | 122 | + CountDownLatch latch = new CountDownLatch(1); |
123 | + Future<String> future = asyncTaskService.saveMessage(sentData, latch); | ||
124 | + latch.await(); | ||
129 | return result; | 125 | return result; |
130 | } | 126 | } |
131 | } | 127 | } |
-
请 注册 或 登录 后发表评论