当消费者在消息处理期间并且在手动ack工作之前抛出异常republishToDlq时,但是原始队列消息总是处于nack状态。 环境 Spring Boot:2.1.11.RELEASE Spring Cloud:Greenwich.SR4 Spring Cloud Stream:Fishtown.SR4 spring-cloud-stream-binder-rabbit:2.1.4.RELEASE Yaml配置 spring: stream: input:
我想以编程的方式在RabbitMQ队列中获得一些确认的和未确认的消息。我使用的是类型记录SDK。我已经搜索过了,但是人们通常建议使用HTTP,这对我来说是没用的。我使用的是一个测试场景,其中我发出X消息,然后根据这些消息执行一些计算。但是,一旦我发送消息“queue.send(testMessage);",消费者还没有收到消息。我在发送消息和根据这些消息执行计算之间设置了一个超时,但这浪费了时间:
import * as