基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 3 元　

支付宝支付

微信支付

   源码介绍

---

package rabbitmq.ycl.config;



import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import rabbitmq.ycl.pojo.UserRabbitMQ;

/**
 * @version V1.0
 * @Description:发送者
 * @author:yuchenglin
 * @date 2020/3/3
 */

@Component
public class Sender {

    private Logger logger = LoggerFactory.getLogger(Sender.class);

    @Autowired
    private AmqpTemplate amqpTemplate;

    public void sendDirectQueue() {
        UserRabbitMQ userRabbitMQ = new UserRabbitMQ();
        userRabbitMQ.setUserId("123456");
        userRabbitMQ.setName("lizhencheng");
        //log.info("【sendDirectQueue已发送消息】");
        logger.info("【sendDirectQueue已发送消息】");
        // 第一个参数是指要发送到哪个队列里面， 第二个参数是指要发送的内容
        this.amqpTemplate.convertAndSend(RabbitMQConfig.QUEUE, userRabbitMQ);
    }

}