RabbitMq消息手动应答,放回队列重新消费,设置队列消息持久化
- 消息手动应答:
编写获取信道工具类
/**
* @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