インターフェース MessagePostProcessor
- すべての既知の実装クラス:
AbstractCompressingPostProcessor
、AbstractDecompressingPostProcessor
、AbstractDeflaterPostProcessor
、DeflaterPostProcessor
、DelegatingDecompressingPostProcessor
、GUnzipPostProcessor
、GZipPostProcessor
、InflaterPostProcessor
、UnzipPostProcessor
、ZipPostProcessor
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
メッセージ変換が実行された後にヘッダーまたはプロパティを追加 / 変更するために使用できる
AmqpTemplate#convertAndSend(Object, MessagePostProcessor)
など、フレームワークのいくつかの場所で使用されます。また、リスナーコンテナーおよび AmqpTemplate
でメッセージを受信するときに、受信メッセージを変更するためにも使用できます。 これは FunctionalInterface
SE であり、ラムダとしてよく使用されます。
amqpTemplate.convertAndSend(routingKey, m -> { m.getMessageProperties().setDeliveryMode(DeliveryMode.NON_PERSISTENT); return m; });
- 作成者:
- Mark Pollack, Gary Russell
メソッドのサマリー
修飾子と型メソッド説明postProcessMessage
(Message message) メッセージを変更 (または置換) します。default Message
postProcessMessage
(Message message, Correlation correlation) メッセージを変更 (または置換) し、その相関データを変更します。default Message
postProcessMessage
(Message message, Correlation correlation, StringSE exchange, StringSE routingKey) メッセージを変更 (または置換) し、その相関データを変更します。
メソッドの詳細
postProcessMessage
メッセージを変更 (または置換) します。- パラメーター:
message
- メッセージ。- 戻り値:
- メッセージ。
- 例外:
AmqpException
- 例外。
postProcessMessage
メッセージを変更 (または置換) し、その相関データを変更します。送信メッセージにのみ適用されます。- パラメーター:
message
- メッセージ。correlation
- 相関データ。- 戻り値:
- メッセージ。
- 導入:
- 1.6.7
postProcessMessage
default Message postProcessMessage(Message message, Correlation correlation, StringSE exchange, StringSE routingKey) メッセージを変更 (または置換) し、その相関データを変更します。送信メッセージにのみ適用されます。- パラメーター:
message
- メッセージ。correlation
- 相関データ。exchange
- メッセージの送信先の交換。routingKey
- ルーティングキー。- 戻り値:
- メッセージ。
- 導入:
- 2.3.4