此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring AMQP 3.2.0! |
自 2.4 以来 3.0 中的更改
观察
现在支持使用 Micrometer 对计时器启用观察和跟踪。 有关更多信息,请参阅千分尺观测。
本机映像
支持创建本机映像。 有关更多信息,请参阅本机映像。
异步兔模板
这AsyncRabbitTemplate 现在返回CompletableFuture s 而不是ListenableFuture s.
有关更多信息,请参阅 Async Rabbit Template 。 |
流支持更改
RabbitStreamOperations 和RabbitStreamTemplate 方法现在返回CompletableFuture 而不是ListenableFuture . |
现在支持 Super 流及其上的单个活动使用者。
有关更多信息,请参阅使用 RabbitMQ Stream 插件。
@RabbitListener
变化
Batch 侦听器现在可以使用Collection<?>
以及List<?>
.
批处理消息传送适配器现在可确保该方法适用于使用批处理。
设置容器工厂时consumerBatchEnabled
自true
这batchListener
property 也被设置为true
.
有关更多信息,请参阅使用 Batching @RabbitListener。
MessageConverter
s 现在可以返回Optional.empty()
对于 null 值;这目前由Jackson2JsonMessageConverter
.
看从Message
了解更多信息
您现在可以配置ReplyPostProcessor
通过 Container Factory 而不是通过@RabbitListener
.
有关更多信息,请参阅回复管理。
这@RabbitListener
(以及@RabbitHandler
) 方法现在可以声明为 Kotlinsuspend
功能。
看异步@RabbitListener
返回类型了解更多信息。
从版本 3.0.5 开始,具有异步返回类型(包括 Kotlin 挂起函数)的侦听器会调用RabbitListenerErrorHandler
(如果已配置)。
以前,错误处理程序仅通过同步调用调用。
连接工厂更改
默认的addressShuffleMode
在AbstractConnectionFactory
现在是RANDOM
.
这会导致在提供多个地址时连接到随机主机。
有关更多信息,请参阅连接到集群。
这LocalizedQueueConnectionFactory
不再使用 RabbitMQhttp-client
库来确定哪个节点是队列的领导者。
看Queue Affinity 和LocalizedQueueConnectionFactory
了解更多信息。