设置使用者绑定属性 delayedExchange 至 true 。
delayedExchange
true
提交已添加 版本1.2 。
的 编辑 强>
@SpringBootApplication @EnableBinding(Sink.class) public class So54986375Application { public static void main(String[] args) { SpringApplication.run(So54986375Application.class, args); } @StreamListener(Sink.INPUT) public void listen(String in) { } }
和
spring.cloud.stream.rabbit.bindings.input.consumer.delayedExchange=true