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