| | |
| | | import cc.mrbird.febs.rabbit.constants.ExchangeConstants; |
| | | import cc.mrbird.febs.rabbit.constants.RouteKeyConstants; |
| | | import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum; |
| | | import cn.hutool.core.util.IdUtil; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.amqp.AmqpException; |
| | | import org.springframework.amqp.core.Message; |
| | |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 添加机器人 |
| | | */ |
| | | public void sendAddRobotMsg(String inviteId) { |
| | | log.info("发送机器人自动抢红包ID:{}", inviteId); |
| | | CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID()); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.IM_REDBAG_GET_ADD_ROBOT.getExchange(), |
| | | RabbitQueueEnum.IM_REDBAG_GET_ADD_ROBOT.getRoute(), |
| | | inviteId, |
| | | correlationData); |
| | | } |
| | | |
| | | } |