【发布时间】：2021-09-25 16:13:07
【问题描述】：
我已经在谷歌上搜索了一段时间，但找不到解决问题的方法。
问题在于 RabbitTemplate 方法的默认行为，即convertSendAndReceive() 和convertSendAndReceiveAsType()。
当您调用这些方法并且它们没有被处理和回复（默认直接回复 queue=amq.rabbitmq.reply-to）时，RabbitTemplate 只会返回 null 响应，而不是指示该消息未得到回复。
当您在队列中发送几乎空的正文并期望收到类似用户的书籍或类似内容时，这一点非常重要，null 响应您无法判断用户是否没有书籍或消息是否没有及时处理。
示例调用
final List<String> messages = rabbitTemplate.convertSendAndReceiveAsType("getMessagesQueue", 0, new ParameterizedTypeReference<>() {});
我找到了一个解决方法 - 使用 AsyncRabbitTemplate，因为它的 RabbitConverterFuture 在方法 .get(timeout) 上抛出异常，但这不是我的首选。我不想使用 AsyncRabbitTemplate 来获取未处理消息的通知。
例子
final AsyncRabbitTemplate.RabbitConverterFuture<List<String>> messages = asyncRabbitTemplate.convertSendAndReceiveAsType("getMessagesQueue", 0, new ParameterizedTypeReference<>() {});
try {
messages.get(5000, TimeUnit.MILLISECONDS);
} catch (InterruptedException | ExecutionException | TimeoutException e) {
// message not processed
}
我的问题是如何配置 RabbitTemplate（配置模板本身，而不是用方面、装饰器、代理或类似的方式包装模板调用）实际上抛出一些异常而不是返回空值。
【问题讨论】：
标签： spring spring-boot rabbitmq spring-amqp spring-rabbit