バッチメッセージ
バッチ処理されたメッセージ (プロデューサーによって作成されたもの) は、リスナーコンテナーによって (springBatchFormat
メッセージヘッダーを使用して) 自動的にバッチ解除されます。バッチからのメッセージを拒否すると、バッチ全体が拒否されます。バッチ処理の詳細については、バッチ処理を参照してください。
バージョン 2.2 から、SimpleMessageListenerContainer
を使用して、コンシューマー側 (プロデューサーが個別のメッセージを送信した場所) でバッチを作成できます。
この機能を有効にするには、コンテナープロパティ consumerBatchEnabled
を設定します。コンテナーが両方の型のバッチの処理を担当するように、deBatchingEnabled
も true にする必要があります。consumerBatchEnabled
が true の場合、BatchMessageListener
または ChannelAwareBatchMessageListener
を実装します。バージョン 2.2.7 以降、SimpleMessageListenerContainer
と DirectMessageListenerContainer
の両方で、プロデューサーが作成したバッチを List<Message>
としてデバッチできます。@RabbitListener
でこの機能を使用する方法については、バッチ処理を伴う @RabbitListener を参照してください。