首页 > 其他分享 >RabbitMq消息手动应答,放回队列重新消费,设置队列消息持久化

RabbitMq消息手动应答,放回队列重新消费,设置队列消息持久化

时间:2022-11-15 10:47:38浏览次数:42  
标签:zjh 队列 应答 factory RabbitMq 消息

RabbitMq消息手动应答,放回队列重新消费,设置队列消息持久化

  1. 消息手动应答:

编写获取信道工具类

/**
 * @author zjh
 */
public class RabbitMqUtils {

    public static Channel getChannel() throws Exception {
        // 创建一个连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 工厂IP 连接RabbitMq的队列
        factory.setHost("localhost);
        // 用户名
        factory.setUsername("zjh");
        // 密码
        factory.setPassword("zjh");

        // 创建连接
        Connection connection = factory.newConnection();
        // 获取信道
        return connection.createChannel();
    }
}

标签:zjh,队列,应答,factory,RabbitMq,消息
From: https://www.cnblogs.com/zjh0420/p/16891595.html

相关文章