rabbitmq 一些参数设置

Java89

rabbitmq 方法的一些参数设置以及解释

消费者采用手动应答

// 采用手动应答 false 采用手动应答,true采用自动应答
boolean autoAck = false;
channel.basicConsume(QUEUE_NAME,autoAck,deliverCallback,cancelCallback);

然后,需要在接收消息的内部类中添加手动应答消息的tag(标记)

```java
// 声明 接收消息
DeliverCallback deliverCallback = (consumerTag, message) ->{
//沉睡
SleepUtils.sleep(30);
System.out.println("接收到的消息:"+new String(message.getBody(),"UTF-8"));

//手动应答
输入验证码查看隐藏内容

扫描二维码关注本站微信公众号 Johngo学长
或者在微信里搜索 Johngo学长
回复 svip 获取验证码
wechat Johngo学长