| | |
| | | * 自动发送 |
| | | */ |
| | | public void sendAutoSendMsg(Long groupId) { |
| | | log.info("自动发送:{}", groupId); |
| | | // log.info("自动发送:{}", groupId); |
| | | CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID()); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getExchange(), |
| | | RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getRoute(), |
| | |
| | | correlationData); |
| | | } |
| | | |
| | | /** |
| | | * 自动返还 |
| | | */ |
| | | public void sendOverdueSendMsg(Long redbagId) { |
| | | log.info("自动返还:{}", redbagId); |
| | | CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID()); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.IM_REDBAG_OVERDUE.getExchange(), |
| | | RabbitQueueEnum.IM_REDBAG_OVERDUE.getRoute(), |
| | | redbagId, |
| | | correlationData); |
| | | } |
| | | |
| | | } |