此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring AMQP 3.2.6! |
批处理消息
批处理消息(由生产者创建)由侦听器容器自动取消批处理(使用springBatchFormat
message header) 的 Message 标头)。
拒绝批处理中的任何邮件会导致整个批处理被拒绝。
有关批处理的更多信息,请参阅批处理。
从 2.2 版开始,SimpleMessageListenerContainer
可用于在消费者端(生产者发送离散消息的地方)创建批处理。
设置容器属性consumerBatchEnabled
以启用此功能。deBatchingEnabled
还必须为 true,以便容器负责处理这两种类型的批次。
实现BatchMessageListener
或ChannelAwareBatchMessageListener
什么时候consumerBatchEnabled
是真的。
从 2.2.7 版开始,两个SimpleMessageListenerContainer
和DirectMessageListenerContainer
可以将生产者创建的批次取消批处理为List<Message>
.
请参阅 @RabbitListener 与批处理 有关将此功能与@RabbitListener
.