版权印作品库

Spring Cloud Stream消费失败后的处理策略(四):重新入队(RabbitMQ)侵权举报

发布日期:2019.02.12

应用场景 之前我们已经通过《Spring Cloud Stream消费失败后的处理策略(一):自动重试》一文介绍了Spring Cloud Stream默认的消息重试功能。本文将介绍RabbitMQ的binder提供的另外一种重试功能:重新入队。

动手试试 准备一个会消费失败的例子,可以直接沿用前文的工程,也可以新建一个,然后创建如下代码的逻辑:

@EnableBinding(TestApplication.TestTopic.class)@SpringBootApplicationpublic class TestApplication { public static void main(String[] args) { SpringApplication.run(TestApplication.class, args); } @RestController static class TestController { @Autowired private TestTopic testTopic; /** * 消息生产接口 * * @param message * @return */ @GetMapping("/sendMessage") public String messageWithMQ(@RequestParam String message) { testTopic.output().send(MessageBuilder.withPayload(message).build()); return "ok"; }...

转载使用

转载使用

不允许编辑作品内容 非专有使用 无转授权
允许在互联网范围内,转载该作品,并在使用时指明作者姓名、作品名称及作品来源。
查看转载使用许可协议
授权价格: 免费
素材使用

素材使用

允许编辑作品内容 非专有使用 无转授权
允许在互联网范围内,作为素材编辑使用该作品,并在使用时可不指明作者姓名、作品名称及作品来源。
查看素材使用许可协议
授权价格: 免费

其他版权作品更多

程序猿DD

信用等级
信用等级B
  • 作品数量420
  • 授权次数317

版权印活动专区更多

  1.  
  2.  
  3.  

版权声明

本作品系本权利人的原创作品,本权利人对本作品享有完整的著作权,任何个人或单位未经许可不得进行任何使用。使用者可以通过版权印平台获取授权在互联网环境下对本作品进行转载使用或素材使用。使用者必须按照授权说明中规定的使用方式使用作品。未获取授权或未按照规定的使用方式使用作品的,都属于侵权行为,将承担相应法律责任。

0