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