Chinaunix首页 | 论坛 | 博客
  • 博客访问: 4248138
  • 博文数量: 447
  • 博客积分: 1241
  • 博客等级: 中尉
  • 技术积分: 5786
  • 用 户 组: 普通用户
  • 注册时间: 2011-01-27 06:48
个人简介

读好书,交益友

文章分类

全部博文(447)

文章存档

2024年(1)

2023年(5)

2022年(29)

2021年(49)

2020年(16)

2019年(15)

2018年(23)

2017年(67)

2016年(42)

2015年(51)

2014年(57)

2013年(52)

2012年(35)

2011年(5)

分类: Java

2020-08-13 16:58:27

因为rabbitmq 提供了java对象json序列化的支持,然后出现了,
Channel shutdown: channel error; protocol method: #method(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)
因为在

点击(此处)折叠或打开

  1. @Bean
  2.     public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
  3.         SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
  4.         factory.setConnectionFactory(connectionFactory);
  5.         factory.setMessageConverter(new Jackson2JsonMessageConverter());

  6.         return factory;
  7.     }
添加了
factory.setMessageConverter(new Jackson2JsonMessageConverter());
rabbitmq的ack 就被设置为自动提交,即使配置文件
添加了

点击(此处)折叠或打开

  1. ## springboot整合rabbitmq的基本配置
  2. spring:
  3. rabbitmq:
  4. addresses: 192.168.10.123:5672
  5. username: xxxx
  6. password: xxxx
  7. virtual-host: /
  8. publisher-confirms: true
  9. publisher-returns: true
  10. template:
  11. mandatory: true

也没有任何作用,只好重新设置
factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);  
阅读(41619) | 评论(0) | 转发(1) |
给主人留下些什么吧!~~