xiaoyong931011
2023-10-11 63a12d1eaaea08d7573e2788156adb7976a8a32d
src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java
@@ -3,6 +3,7 @@
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;
@@ -45,4 +46,16 @@
    }
    /**
     * 添加机器人
     */
    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);
    }
}