|
@@ -129,7 +129,7 @@ public class DeptServiceImpl extends ServiceImpl<DeptMapper, Dept> implements De
|
|
|
msgLog.setExchange(GroupConsumeConfig.NAME);
|
|
|
msgLog.setRoutingKey(GroupConsumeConfig.NAME);
|
|
|
msgLog.setMsg(JSON.toJSONString(map));
|
|
|
- msgLogService.save(msgLog);
|
|
|
+ msgLogService.addOrUpdate(msgLog);
|
|
|
map.put("seq",msgLog.getId());
|
|
|
CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
|
|
|
groupRabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), map,correlationData);
|