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