spring cloud stream ack 实现 [rabbimq消费者实现]


?

关键配置:


spring.cloud.stream.rabbit.bindings.input.consumer.acknowledge-mode=manual
spring.cloud.stream.rabbit.bindings.input1.consumer.acknowledge-mode=manual

关键代码:


?


@StreamListener("input")
public void receive(Message entityMessage,
@Header(AmqpHeaders.CHANNEL) Channel channel,
@Header(AmqpHeaders.DELIVERY_TAG) Long deliveryTag) throws Exception {

if (entityMessage.getPayload() == null ||
StringUtils.isBlank(entityMessage.getPayload().getId())) {
//记录日志
}
try {
channel.basicAck(deliveryTag, false);//手动确认
} catch (Exception ex) {
//记录日志
}
//
//
}

@StreamListener("input1")
public void receive1(
Entity entityMessage,
@Header(AmqpHeaders.CHANNEL) Channel channel,
@Header(AmqpHeaders.DELIVERY_TAG) Long deliveryTag) throws Exception {

if (entityMessage== null ||
StringUtils.isBlank(entityMessage.getId())) {
//记录日志
}
try {
channel.basicAck(deliveryTag, false);//手动确认
} catch (Exception ex) {
//记录日志
}
//
//


}

?


?


?


?


?


?

相关文档

  • 播音主持如何正确发音
  • 竞选副主席的演讲稿
  • 孕妇血小板低对胎儿有什么影响,孕妇血小板低对胎儿的影响,孕妇血小板低的影响
  • 2020年对读书的感悟精品作文
  • 算法导论学习笔记-第十七章-平摊分析
  • 幼儿小班数学教学计划
  • 师生篮球赛活动方案
  • 蓝牙耳机的优点
  • 洞悉MySQL底层架构:游走在缓冲与磁盘之间
  • 怎样发送excel表格中多个表格其中的一个
  • 拍沪牌需要什么条件
  • 春季运动会演讲稿
  • 名家西游记读后感
  • 保险部门经理年终总结
  • 销售团队职场正能量语录
  • 抹茶粉可以直接泡水喝吗功效与禁忌
  • 苹果xsmax用18w快充伤电池吗
  • 2021年公司普通员工个人总结
  • 小学一年级作文:转呼啦圈
  • 朗逸怎么用内存卡听歌
  • 华为路由器配置大全
  • Redis之RDB与AOF 笔记
  • 关于著名的经典诗句集萃
  • 炒红萝卜
  • 斯里兰卡蓝宝石多少钱一克拉价值连城
  • 比特币源码阅读 ?? 签名的内容 (对进行签名)
  • 关于著作权转让合同范本商用光盘
  • 大学生校园吉尼斯活动策划书
  • 致打工父母一封信
  • 有关于感恩父母的句子欣赏
  • 电脑版