Batched Messages
批处理消息(由生产者创建)由侦听器容器(使用 springBatchFormat
消息头)自动解除批处理。拒绝批处理中的任何消息都会导致拒绝整个批处理。有关批处理的更多信息,请参见 Batching。
从版本 2.2 开始,SimpleMessageListenerContainer
可用于在消费者侧创建批次(生产者发送离散消息)。
设置容器属性 consumerBatchEnabled
以启用此功能。deBatchingEnabled
也必须为 true,以便容器负责处理这两种类型的批处理。在 consumerBatchEnabled
为 true 时实现 BatchMessageListener
或 ChannelAwareBatchMessageListener
。从版本 2.2.7 开始,SimpleMessageListenerContainer
和 DirectMessageListenerContainer
都可以将 producer created batches 解除批处理,就像 List<Message>
一样。有关将此功能与 @RabbitListener
一起使用的信息,请参见 @RabbitListener with Batching。